danielhopkins

Got this working under jruby 1.6.5 with trinidad as a webserver (webbrick doesn't seem to work)

danielhopkins

class TryIt
  def []=(k,v) return "I'm a return value, if I'm not returned where do I go?" end
end

t = TryIt.new
puts(t['blah'] = "It would be slightly surprising if I were returned, right?")
#=> "It would be slightly surprising if I were returned, right?"

danielhopkins

/*
 * Copyright 2006 Sun Microsystems, Inc.  All Rights Reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 *   - Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 *

danielhopkins

#!/usr/bin/env ruby
require 'rubygems'
require 'dropbox_sdk'

APP_KEY       = 'h45ed6ebm2zxius'
APP_SECRET    = '14uzh0u8myosnbn'
ACCESS_TYPE   = :dropbox
PASSWD_FILE   = "#{ENV['HOME']}/.dblink"

def run

danielhopkins

import java.io._
import java.nio._
import java.nio.channels._

/*
Initially I wanted to explore the nio api for file access and I ended up coming across a SO article
saying that nio isn't faster than just plain 'ol FileOutputStream. Curious about this I came up with
a benchmark suite and quickly found that is indeed true. After a couple of iterations I was able to
beat the default, but clearly it's not easy or obvious.

danielhopkins

// We're trying to express a future that can timeout but I don't
// want to use Await and block the current thread. I need to return
// a future that is either timed out or the value of the completed future

import concurrent.ExecutionContext.Implicits._
import concurrent.Future
import concurrent._
import concurrent.duration._
import akka.pattern.after
import scala.util.{Try, Success, Failure}

danielhopkins

# from .git_functions
function git_helpers_clean_remote() {
  remote=$1
  git ls-remote -h $remote |
  git show-ref --heads --exclude-existing |
  cut -f 2 | xargs git push --delete $remote
}

# from .gitconfig
[alias]

danielhopkins

/*
The general idea is to handle timeouts as a message instead of using callbacks or worse yet, blocking
the actor (as I do below)
*/

val system = ActorSystem()
val myactor = system.actorOf(Props[MyActor])
val someotheractor = system.actorOf(Props[SomeotherActor])

class MyActor extends Actor with ActorLogging {

danielhopkins

class EchoActor extends Actor with ActorLogging {
  val cluster = Cluster(context.system)
  override def preStart() { cluster.subscribe(self, classOf[LeaderChanged]) }

  override def postStop() { cluster.unsubscribe(self) }

  def receive = {
    case state: CurrentClusterState => log.info(s"State is $state")
    case LeaderChanged(leader)      => log.info(s"Leader is $leader")
    case msg => {

danielhopkins

This link