diff options
| author | Li Haoyi <haoyi.li@databricks.com> | 2019-09-16 22:31:03 +0800 |
|---|---|---|
| committer | Li Haoyi <haoyi.li@databricks.com> | 2019-09-16 22:31:03 +0800 |
| commit | bfe26d5a9705011359658c45b364e9b65ce697b5 (patch) | |
| tree | 656565b3d147b1837d4cfc1d949e7af8c250f16c /example/websockets/app/src/Websockets.scala | |
| parent | 84ea971b1261919aca7b31635ddc7d0dca830fea (diff) | |
| download | cask-bfe26d5a9705011359658c45b364e9b65ce697b5.tar.gz cask-bfe26d5a9705011359658c45b364e9b65ce697b5.tar.bz2 cask-bfe26d5a9705011359658c45b364e9b65ce697b5.zip | |
Provide a simple builtin websocket client in `cask.WsClient`
Harmonize the actor-based APIs of `cask.WsClient`/`cask.WsHandler`/`cask.WsActor`, letting them share the same set of `cask.Ws` events
The default implementation of `cask.WsClient` on the JVM spawns one thread per connection, and doesn't really scale to large numbers of connections. For now we just continue using AsyncHttpClient in the load tests. Wrapping AsyncHttpClient in a nice API is TBD
Diffstat (limited to 'example/websockets/app/src/Websockets.scala')
| -rw-r--r-- | example/websockets/app/src/Websockets.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/example/websockets/app/src/Websockets.scala b/example/websockets/app/src/Websockets.scala index fe32c5d..997c1ce 100644 --- a/example/websockets/app/src/Websockets.scala +++ b/example/websockets/app/src/Websockets.scala @@ -6,9 +6,9 @@ object Websockets extends cask.MainRoutes{ if (userName != "haoyi") cask.Response("", statusCode = 403) else cask.WsHandler { channel => cask.WsActor { - case cask.WsActor.Text("") => channel.send(cask.WsActor.Close()) - case cask.WsActor.Text(data) => - channel.send(cask.WsActor.Text(userName + " " + data)) + case cask.Ws.Text("") => channel.send(cask.Ws.Close()) + case cask.Ws.Text(data) => + channel.send(cask.Ws.Text(userName + " " + data)) } } } |