| Index: tests/standalone/src/EchoServerStreamReadUntilTest.dart
|
| diff --git a/tests/standalone/src/EchoServerStreamReadUntilTest.dart b/tests/standalone/src/EchoServerStreamReadUntilTest.dart
|
| index e8df2282668230572adde6a9bc793a730bbfa616..33a035aec62ecaa92d4c35d720559599bcbafa19 100644
|
| --- a/tests/standalone/src/EchoServerStreamReadUntilTest.dart
|
| +++ b/tests/standalone/src/EchoServerStreamReadUntilTest.dart
|
| @@ -3,6 +3,11 @@
|
| // BSD-style license that can be found in the LICENSE file.
|
| //
|
| // Echo server test program to test socket stream read until functionality.
|
| +//
|
| +// VMOptions=
|
| +// VMOptions=--short_socket_read
|
| +// VMOptions=--short_socket_write
|
| +// VMOptions=--short_socket_read --short_socket_write
|
|
|
| main() {
|
| EchoServerStreamReadUntilTest.testMain();
|
| @@ -146,12 +151,17 @@ class EchoServer extends Isolate {
|
| for (int i = 0; i < MSGSIZE - 1; i++) {
|
| Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]);
|
| }
|
| - outputStream.write(buffer, 0, buffer.length, null);
|
| - inputStream.readUntil(PATTERN2, dataReceived);
|
| + void next() {
|
| + inputStream.readUntil(PATTERN2, dataReceived);
|
| + inputStream.readUntil(PATTERN2, dataReceived);
|
| + }
|
| + bool done = outputStream.write(buffer, 0, buffer.length, next);
|
| + if (done) {
|
| + next();
|
| + }
|
| } else {
|
| Expect.equals(1, buffer.length);
|
| outputStream.write(buffer, 0, buffer.length, null);
|
| - inputStream.readUntil(PATTERN2, dataReceived);
|
| }
|
| }
|
|
|
|
|