Skip to content

Instantly share code, notes, and snippets.

@dosht
dosht / gist:4d5445c92e71d46af971
Last active August 29, 2015 14:03
XHR polling and streaming for sockjs
package com.cloud9ers.play2.sockjs.transports
import scala.Array.canBuildFrom
import scala.concurrent.Promise
import scala.concurrent.duration.DurationInt
import org.codehaus.jackson.JsonParseException
import com.cloud9ers.play2.sockjs.{ JsonCodec, Session, SockJsFrames }
import akka.actor.{ ActorRef, PoisonPill, Props, actorRef2Scala }
import play.api.libs.concurrent.Execution.Implicits.defaultContext
import play.api.libs.iteratee.Concurrent
@dosht
dosht / gist:f3204668917c2bee0afb
Created July 7, 2014 10:21
SockJS handler inspired from play websockets and sockjs implementation of vert.x
package com.cloud9ers.play2.sockjs
import java.text.SimpleDateFormat
import java.util.Date
import scala.Option.option2Iterable
import scala.concurrent.Future
import scala.concurrent.duration.DurationInt
import scala.util.Random
import com.cloud9ers.play2.sockjs.transports.{ EventSourceTransport, JsonPTransport, Transport, WebSocketTransport, XhrTransport }
import akka.actor.{ ActorRef, actorRef2Scala }
@dosht
dosht / HelloActor.scala
Created October 26, 2013 09:50
Hello World Example for Akka Actors
import akka.actor.{ Actor, ActorSystem, Props }
import scala.concurrent.duration._
class HelloActor extends Actor {
def receive = {
case "exit" => context.system.shutdown()
case message => println(message)
}
}