| Index: tests/standalone/src/EchoServerTest.dart
|
| diff --git a/tests/standalone/src/EchoServerTest.dart b/tests/standalone/src/EchoServerTest.dart
|
| index 23065628c207490bf2e3c872e231fd04a8ae0551..78f358d7fe8d9115fcd8277d5b5aefc422109b42 100644
|
| --- a/tests/standalone/src/EchoServerTest.dart
|
| +++ b/tests/standalone/src/EchoServerTest.dart
|
| @@ -21,7 +21,7 @@ class EchoServerGame {
|
| static final MSGSIZE = 10;
|
| static final SERVERINIT = 0;
|
| static final SERVERSHUTDOWN = -1;
|
| - static final MESSAGES = 200;
|
| + static final MESSAGES = 100;
|
| static final FIRSTCHAR = 65;
|
|
|
| EchoServerGame.start()
|
| @@ -73,13 +73,8 @@ class EchoServerGame {
|
| handleRead();
|
| }
|
|
|
| - void closeHandler() {
|
| - _socket.close();
|
| - }
|
| -
|
| void errorHandler() {
|
| - print("Socket error");
|
| - _socket.close();
|
| + Expect.fail("Socket error");
|
| }
|
|
|
| void connectHandler() {
|
| @@ -99,7 +94,6 @@ class EchoServerGame {
|
| }
|
|
|
| _socket.dataHandler = messageHandler;
|
| - _socket.closeHandler = closeHandler;
|
| _socket.errorHandler = errorHandler;
|
| writeMessage();
|
| }
|
| @@ -108,7 +102,7 @@ class EchoServerGame {
|
| if (_socket !== null) {
|
| _socket.connectHandler = connectHandler;
|
| } else {
|
| - Expect.fail("socket creation failed");
|
| + Expect.fail("Socket creation failed");
|
| }
|
| }
|
|
|
| @@ -174,6 +168,8 @@ class EchoServer extends Isolate {
|
| bytesWritten += written;
|
| if (bytesWritten < msgSize) {
|
| _client.writeHandler = handleWrite;
|
| + } else {
|
| + _client.close(true);
|
| }
|
| }
|
| handleWrite();
|
| @@ -191,8 +187,7 @@ class EchoServer extends Isolate {
|
| }
|
|
|
| void errorHandler() {
|
| - print("Socket error");
|
| - _client.close();
|
| + Expect.fail("Socket error");
|
| }
|
|
|
| _client = _server.accept();
|
| @@ -202,8 +197,7 @@ class EchoServer extends Isolate {
|
| }
|
|
|
| void errorHandlerServer() {
|
| - print("Server socket error");
|
| - _server.close();
|
| + Expect.fail("Server socket error");
|
| }
|
|
|
| this.port.receive((message, SendPort replyTo) {
|
|
|