Index: runtime/bin/stream_util.dart |
diff --git a/runtime/bin/stream_util.dart b/runtime/bin/stream_util.dart |
index 03efc36ebd6252988612bfe8ec94e45e9ab7a032..9c27c2b9420ec208a6d52b99b0a35e60a2bfbe9a 100644 |
--- a/runtime/bin/stream_util.dart |
+++ b/runtime/bin/stream_util.dart |
@@ -43,17 +43,17 @@ class _BaseDataInputStream { |
bool get closed() => _closeCallbackCalled; |
- void set dataHandler(void callback()) { |
+ void set onData(void callback()) { |
_clientDataHandler = callback; |
_checkScheduleCallbacks(); |
} |
- void set closeHandler(void callback()) { |
+ void set onClosed(void callback()) { |
_clientCloseHandler = callback; |
_checkScheduleCallbacks(); |
} |
- void set errorHandler(void callback()) { |
+ void set onError(void callback()) { |
_clientErrorHandler = callback; |
} |
@@ -150,8 +150,8 @@ void _pipe(InputStream input, OutputStream output, [bool close]) { |
List<int> data; |
while ((data = input.read()) !== null) { |
if (!output.write(data)) { |
- input.dataHandler = null; |
- output.noPendingWriteHandler = pipeNoPendingWriteHandler; |
+ input.onData = null; |
+ output.onNoPendingWrites = pipeNoPendingWriteHandler; |
break; |
} |
} |
@@ -165,13 +165,13 @@ void _pipe(InputStream input, OutputStream output, [bool close]) { |
}; |
pipeNoPendingWriteHandler = () { |
- input.dataHandler = pipeDataHandler; |
- output.noPendingWriteHandler = null; |
+ input.onData = pipeDataHandler; |
+ output.onNoPendingWrites = null; |
}; |
_inputCloseHandler = input._clientCloseHandler; |
- input.dataHandler = pipeDataHandler; |
- input.closeHandler = pipeCloseHandler; |
- output.noPendingWriteHandler = null; |
+ input.onData = pipeDataHandler; |
+ input.onClosed = pipeCloseHandler; |
+ output.onNoPendingWrites = null; |
} |