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()); |
} |