internal…

InJvmBroadcasterClient.scala
View Options

			package net.shrine.broadcaster

			import net.shrine.protocol.BroadcastMessage
			import scala.concurrent.Future
			import net.shrine.protocol.SingleNodeResult

			/**
			* @author clint
			* @date Feb 28, 2014
			*/
			final case class InJvmBroadcasterClient(broadcaster: Broadcaster) extends BroadcasterClient {
			override def broadcast(message: BroadcastMessage): Future[Iterable[SingleNodeResult]] = {
			broadcaster.broadcast(message).responses
			}
			}