From a873d77fbeb4590dceeb893ab067beb9058db241 Mon Sep 17 00:00:00 2001 From: Li Haoyi Date: Mon, 13 Aug 2018 15:00:14 +0800 Subject: Tweak websocket tests, example and docs --- example/websockets/app/src/Websockets.scala | 8 ++++---- example/websockets/app/test/src/ExampleTests.scala | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) (limited to 'example/websockets/app') 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{ -- cgit v1.2.3