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) { |