diff options
Diffstat (limited to 'cask/src/cask/endpoints/WebSocketEndpoint.scala')
| -rw-r--r-- | cask/src/cask/endpoints/WebSocketEndpoint.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cask/src/cask/endpoints/WebSocketEndpoint.scala b/cask/src/cask/endpoints/WebSocketEndpoint.scala index a836321..fae7fde 100644 --- a/cask/src/cask/endpoints/WebSocketEndpoint.scala +++ b/cask/src/cask/endpoints/WebSocketEndpoint.scala @@ -2,7 +2,7 @@ package cask.endpoints import java.nio.ByteBuffer -import cask.internal.{BatchActor, Router} +import cask.internal.Router import cask.model.Request import cask.util.Logger import io.undertow.websockets.WebSocketConnectionCallback @@ -32,7 +32,7 @@ class websocket(val path: String, override val subpath: Boolean = false) def wrapPathSegment(s: String): Seq[String] = Seq(s) } -case class WsHandler(f: WsChannelActor => BatchActor[WsActor.Event]) +case class WsHandler(f: WsChannelActor => cask.util.BatchActor[WsActor.Event]) (implicit ec: ExecutionContext, log: Logger) extends WebsocketResult with WebSocketConnectionCallback { def onConnect(exchange: WebSocketHttpExchange, channel: WebSocketChannel): Unit = { @@ -71,7 +71,7 @@ extends WebsocketResult with WebSocketConnectionCallback { class WsChannelActor(channel: WebSocketChannel) (implicit ec: ExecutionContext, log: Logger) -extends BatchActor[WsActor.Event]{ +extends cask.util.BatchActor[WsActor.Event]{ def run(items: Seq[WsActor.Event]): Unit = items.foreach{ case WsActor.Text(value) => WebSockets.sendTextBlocking(value, channel) case WsActor.Binary(value) => WebSockets.sendBinaryBlocking(ByteBuffer.wrap(value), channel) @@ -83,7 +83,7 @@ extends BatchActor[WsActor.Event]{ case class WsActor(handle: PartialFunction[WsActor.Event, Unit]) (implicit ec: ExecutionContext, log: Logger) -extends BatchActor[WsActor.Event]{ +extends cask.util.BatchActor[WsActor.Event]{ def run(items: Seq[WsActor.Event]): Unit = { items.foreach(handle.applyOrElse(_, (x: WsActor.Event) => ())) } |