ExampleApp.scala

import akka.actor._
import akka.util.ByteString
import spray.http.HttpEntity.Empty
import spray.http.MediaTypes._
import spray.http._
import spray.routing.{HttpService, RequestContext, SimpleRoutingApp}
 
object ChunkedSpray extends App with SimpleRoutingApp {
 
  import StreamingActor._
 
  implicit val actorSystem = ActorSystem()
 
  lazy val stream: Stream[String] = "first" #:: "second" #:: "third" #:: Stream.empty
 
  lazy val emptyStream: Stream[Array[Byte]] = Stream.empty
 
  startServer(interface = "localhost", port = 8080) {
    get {
      path("stream") {
        ctx =>
          actorRefFactory.actorOf(fromString(stream, ctx))
      } ~
      path("empty-stream") {
        ctx =>
          actorRefFactory.actorOf(fromByteArray(emptyStream, ctx))
      }
    }
  }
}