| Index: tests/standalone/src/ListInputStreamTest.dart
|
| diff --git a/tests/standalone/src/ListInputStreamTest.dart b/tests/standalone/src/ListInputStreamTest.dart
|
| index 7248592429022b420ee7abf0d523b2f455c22f16..8c8efaf3e31bfb7063e265786d964e431a94b8f6 100644
|
| --- a/tests/standalone/src/ListInputStreamTest.dart
|
| +++ b/tests/standalone/src/ListInputStreamTest.dart
|
| @@ -19,8 +19,8 @@ void testEmptyListInputStream() {
|
| donePort.toSendPort().send(null);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
| @@ -37,8 +37,8 @@ void testEmptyDynamicListInputStream() {
|
| donePort.toSendPort().send(null);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
| stream.markEndOfStream();
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| @@ -63,8 +63,8 @@ void testListInputStream1() {
|
| donePort.toSendPort().send(count);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
| @@ -90,8 +90,8 @@ void testListInputStream2() {
|
| donePort.toSendPort().send(count);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
| @@ -110,7 +110,7 @@ void testListInputStreamPipe1() {
|
| donePort.toSendPort().send(null);
|
| }
|
|
|
| - input.closeHandler = onClose;
|
| + input.onClose = onClose;
|
| input.pipe(output);
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| @@ -127,7 +127,7 @@ void testListInputStreamPipe2() {
|
| InputStream input = new ListInputStream();
|
| input.write(data);
|
| input.markEndOfStream();
|
| - input.closeHandler = onClose;
|
| + input.onClose = onClose;
|
| if (count < 9) {
|
| input.pipe(output, close: false);
|
| } else {
|
| @@ -144,7 +144,7 @@ void testListInputStreamPipe2() {
|
| InputStream input = new ListInputStream();
|
| input.write(data);
|
| input.markEndOfStream();
|
| - input.closeHandler = onClose;
|
| + input.onClose = onClose;
|
| input.pipe(output, close: false);
|
| count++;
|
|
|
| @@ -166,8 +166,8 @@ void testListInputClose1() {
|
| donePort.toSendPort().send(null);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
| stream.close();
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| @@ -191,8 +191,8 @@ void testListInputClose2() {
|
| donePort.toSendPort().send(count);
|
| }
|
|
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
| @@ -222,8 +222,8 @@ void testDynamicListInputStream() {
|
| }
|
|
|
| stream.write(data);
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
| @@ -242,8 +242,8 @@ void testDynamicListInputClose1() {
|
| }
|
|
|
| stream.write(data);
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
| stream.close();
|
| Expect.throws(() => stream.write(data), (e) => e is StreamException);
|
|
|
| @@ -270,8 +270,8 @@ void testDynamicListInputClose2() {
|
| stream.write(data);
|
| stream.write(data);
|
| stream.write(data);
|
| - stream.dataHandler = onData;
|
| - stream.closeHandler = onClose;
|
| + stream.onData = onData;
|
| + stream.onClose = onClose;
|
|
|
| donePort.receive((x,y) => donePort.close());
|
| }
|
|
|