From 9be09d4f6961e80ef3fccda1e82dc063d395494f Mon Sep 17 00:00:00 2001 From: Li Haoyi Date: Thu, 7 Nov 2019 13:07:06 +0800 Subject: 0.3.6 --- cask/src/cask/endpoints/WebSocketEndpoint.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'cask/src/cask/endpoints/WebSocketEndpoint.scala') diff --git a/cask/src/cask/endpoints/WebSocketEndpoint.scala b/cask/src/cask/endpoints/WebSocketEndpoint.scala index fcb40ec..d96d6ac 100644 --- a/cask/src/cask/endpoints/WebSocketEndpoint.scala +++ b/cask/src/cask/endpoints/WebSocketEndpoint.scala @@ -32,8 +32,8 @@ class websocket(val path: String, override val subpath: Boolean = false) def wrapPathSegment(s: String): Seq[String] = Seq(s) } -case class WsHandler(f: WsChannelActor => cask.actor.Actor[Ws.Event]) - (implicit ac: cask.actor.Context, log: Logger) +case class WsHandler(f: WsChannelActor => castor.Actor[Ws.Event]) + (implicit ac: castor.Context, log: Logger) extends WebsocketResult with WebSocketConnectionCallback { def onConnect(exchange: WebSocketHttpExchange, channel: WebSocketChannel): Unit = { channel.suspendReceives() @@ -75,8 +75,8 @@ extends WebsocketResult with WebSocketConnectionCallback { } class WsChannelActor(channel: WebSocketChannel) - (implicit ac: cask.actor.Context, log: Logger) -extends cask.actor.SimpleActor[Ws.Event]{ + (implicit ac: castor.Context, log: Logger) +extends castor.SimpleActor[Ws.Event]{ def run(item: Ws.Event): Unit = item match{ case Ws.Text(value) => WebSockets.sendTextBlocking(value, channel) case Ws.Binary(value) => WebSockets.sendBinaryBlocking(ByteBuffer.wrap(value), channel) @@ -87,8 +87,8 @@ extends cask.actor.SimpleActor[Ws.Event]{ } case class WsActor(handle: PartialFunction[Ws.Event, Unit]) - (implicit ac: cask.actor.Context, log: Logger) -extends cask.actor.SimpleActor[Ws.Event]{ + (implicit ac: castor.Context, log: Logger) +extends castor.SimpleActor[Ws.Event]{ def run(item: Ws.Event): Unit = { handle.lift(item) } -- cgit v1.2.3