* Pluggable response handlers;

It's possible to stream content towards Sentinel clients by sending the `StreamedOperation` command to a Sentinel Client:

client.streamCommands[TotalSize, Chunk](Enumerator(chunks: _*))

The function is annotated with the expected returning type (`TotalSize` in this case) and the type used within the `Enumerator` (`Chunk` in this case). The function takes a **Play 2** Enumerator as argument, which is folded to send each item to the TCP connection.

To handle incoming streams, a `EnumeratorStage` is available in Sentinel. Initialisation of `EnumeratorStage` takes two arguments: `terminator: Evt ⇒ Boolean` and `includeTerminator: Boolean = false`.

This first argument is a function taking each `Evt` and returning a boolean in case the streamed chunk can be treated as a `EOS`. The second argument is used to declare if the terminator should be included in the eventual stream of content.

A simple example can be found in the [Iteratee Spec](https://github.com/gideondk/sentinel/blob/master/src/test/scala/nl/gideondk/sentinel/IterateeSpec.scala).

version := "0.5.0-SNAPSHOT",

import scala.concurrent.{ ExecutionContext, Future, Promise }

import scala.concurrent.duration.{ DurationInt, FiniteDuration }

import akka.actor.{ Actor, ActorSystem, Props, Stash, actorRef2Scala }

import akka.io.{ PipePair, PipelineContext, PipelineStage }

val p = Promise[Option[Evt]]()

channels = channels ++ Map(identifier -> c.copy(hook = Some(p)))

p

}

def newHandlerActor(init: Init[WithinActorContext, Cmd, Evt]) = system.actorOf(Props(new SentinelServerBasicAsyncHandler(init, handler)).withDispatcher("nl.gideondk.sentinel.sentinel-dispatcher"))

import akka.io.{ LengthFieldFrame, PipePair, PipelineContext, PipelineStage }

import akka.util.{ ByteString, ByteStringBuilder }

import client.{ SentinelClient, commandable }

import play.api.libs.iteratee.{ Enumerator, Iteratee }