diff options
author | Li Haoyi <haoyi.sg@gmail.com> | 2019-11-07 13:07:06 +0800 |
---|---|---|
committer | Li Haoyi <haoyi.sg@gmail.com> | 2019-11-07 13:07:40 +0800 |
commit | 9be09d4f6961e80ef3fccda1e82dc063d395494f (patch) | |
tree | edcbb6a1d48f6c8eb5a6ffd425b08065f18f101e /cask/util/src/cask/util | |
parent | 1d52dd1c848d245c269a7a274602fdf57e47cac9 (diff) | |
download | cask-9be09d4f6961e80ef3fccda1e82dc063d395494f.tar.gz cask-9be09d4f6961e80ef3fccda1e82dc063d395494f.tar.bz2 cask-9be09d4f6961e80ef3fccda1e82dc063d395494f.zip |
0.3.60.3.6
Diffstat (limited to 'cask/util/src/cask/util')
-rw-r--r-- | cask/util/src/cask/util/WsClient.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cask/util/src/cask/util/WsClient.scala b/cask/util/src/cask/util/WsClient.scala index 28277bb..63995c7 100644 --- a/cask/util/src/cask/util/WsClient.scala +++ b/cask/util/src/cask/util/WsClient.scala @@ -4,8 +4,8 @@ import scala.concurrent.duration.Duration import scala.concurrent.{Await, ExecutionContext, Promise} class WsClient(impl: WebsocketBase) - (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(s) => impl.send(s) @@ -18,13 +18,13 @@ class WsClient(impl: WebsocketBase) object WsClient{ def connect(url: String) (f: PartialFunction[cask.util.Ws.Event, Unit]) - (implicit ac: cask.actor.Context, log: Logger): WsClient = { + (implicit ac: castor.Context, log: Logger): WsClient = { Await.result(connectAsync(url)(f), Duration.Inf) } def connectAsync(url: String) (f: PartialFunction[cask.util.Ws.Event, Unit]) - (implicit ac: cask.actor.Context, log: Logger): scala.concurrent.Future[WsClient] = { - object receiveActor extends cask.actor.SimpleActor[Ws.Event] { + (implicit ac: castor.Context, log: Logger): scala.concurrent.Future[WsClient] = { + object receiveActor extends castor.SimpleActor[Ws.Event] { def run(item: Ws.Event) = f.lift(item) } val p = Promise[WsClient] |