Index: sdk/lib/io/chunked_stream.dart |
diff --git a/sdk/lib/io/chunked_stream.dart b/sdk/lib/io/chunked_stream.dart |
index c74a057cb0570538f46abddb14509a684cf53e8f..07fd9b46858c0f485e56847f1ac620e6a0e638af 100644 |
--- a/sdk/lib/io/chunked_stream.dart |
+++ b/sdk/lib/io/chunked_stream.dart |
@@ -92,7 +92,7 @@ class _ChunkedInputStream implements ChunkedInputStream { |
void _checkScheduleCallback() { |
// TODO(sgjesse): Find a better way of scheduling callbacks from |
// the event loop. |
- void issueDataCallback(Timer timer) { |
+ void issueDataCallback() { |
_scheduledDataCallback = null; |
if (_clientDataHandler != null) { |
_clientDataHandler(); |
@@ -100,7 +100,7 @@ class _ChunkedInputStream implements ChunkedInputStream { |
} |
} |
- void issueCloseCallback(Timer timer) { |
+ void issueCloseCallback() { |
_scheduledCloseCallback = null; |
if (!_closed) { |
if (_clientCloseHandler != null) _clientCloseHandler(); |
@@ -113,7 +113,7 @@ class _ChunkedInputStream implements ChunkedInputStream { |
(_bufferList.length > 0 && _inputClosed)) && |
_clientDataHandler != null && |
_scheduledDataCallback == null) { |
- _scheduledDataCallback = new Timer(0, issueDataCallback); |
+ _scheduledDataCallback = Timer.run(issueDataCallback); |
} |
// Schedule close callback if no more data and input is closed. |
@@ -124,7 +124,7 @@ class _ChunkedInputStream implements ChunkedInputStream { |
if (_scheduledDataCallback != null) { |
_scheduledDataCallback.cancel(); |
} |
- _scheduledCloseCallback = new Timer(0, issueCloseCallback); |
+ _scheduledCloseCallback = Timer.run(issueCloseCallback); |
} |
} |