diff options
author | Li Haoyi <haoyi.sg@gmail.com> | 2018-08-13 15:00:14 +0800 |
---|---|---|
committer | Li Haoyi <haoyi.sg@gmail.com> | 2018-08-13 15:25:11 +0800 |
commit | a873d77fbeb4590dceeb893ab067beb9058db241 (patch) | |
tree | 3132f93c3f78206ad3ca7af8dd7f04a116c216ed /example/websockets/app | |
parent | 3ff5a5079080de524375cd43425c1515bf128274 (diff) | |
download | cask-a873d77fbeb4590dceeb893ab067beb9058db241.tar.gz cask-a873d77fbeb4590dceeb893ab067beb9058db241.tar.bz2 cask-a873d77fbeb4590dceeb893ab067beb9058db241.zip |
Tweak websocket tests, example and docs
Diffstat (limited to 'example/websockets/app')
-rw-r--r-- | example/websockets/app/src/Websockets.scala | 8 | ||||
-rw-r--r-- | example/websockets/app/test/src/ExampleTests.scala | 2 |
2 files changed, 5 insertions, 5 deletions
diff --git a/example/websockets/app/src/Websockets.scala b/example/websockets/app/src/Websockets.scala index 277b06f..a6ceb73 100644 --- a/example/websockets/app/src/Websockets.scala +++ b/example/websockets/app/src/Websockets.scala @@ -13,14 +13,14 @@ object Websockets extends cask.MainRoutes{ channel.getReceiveSetter.set( new AbstractReceiveListener() { override def onFullTextMessage(channel: WebSocketChannel, message: BufferedTextMessage) = { - val data = message.getData - if (data == "") channel.close() - else WebSockets.sendTextBlocking(userName + " " + data, channel) + message.getData match{ + case "" => channel.close() + case data => WebSockets.sendTextBlocking(userName + " " + data, channel) + } } } ) channel.resumeReceives() - } } } diff --git a/example/websockets/app/test/src/ExampleTests.scala b/example/websockets/app/test/src/ExampleTests.scala index 403fde0..969750c 100644 --- a/example/websockets/app/test/src/ExampleTests.scala +++ b/example/websockets/app/test/src/ExampleTests.scala @@ -105,7 +105,7 @@ object ExampleTests extends TestSuite{ w.sendTextFrame("") Thread.sleep(1) } - Thread.sleep(1500) + Thread.sleep(2000) out.length ==> 2000 }finally{ |