Index: sdk/lib/io/secure_socket.dart |
diff --git a/sdk/lib/io/secure_socket.dart b/sdk/lib/io/secure_socket.dart |
index c1f40db91ed87817ace2ad5633e1ae8b445d4660..d9e5e23b54729ad80bf4e68d8442d2acf0de086e 100644 |
--- a/sdk/lib/io/secure_socket.dart |
+++ b/sdk/lib/io/secure_socket.dart |
@@ -389,7 +389,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
_controller.hasSubscribers && |
_secureFilter != null && |
_secureFilter.buffers[WRITE_PLAINTEXT].free > 0) { |
- new Timer(0, (_) => _controller.add(RawSocketEvent.WRITE)); |
+ Timer.run(() => _controller.add(RawSocketEvent.WRITE)); |
} else { |
_writeEventsEnabled = value; |
} |
@@ -402,7 +402,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
if (_socketClosedRead) { |
if (value) { |
// We have no underlying socket to set off read events. |
- new Timer(0, (_) => _readHandler()); |
+ Timer.run(_readHandler); |
} |
} |
} |
@@ -432,7 +432,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
// Set up a read event if the filter still has data. |
if (!_filterReadEmpty) { |
- new Timer(0, (_) => _readHandler()); |
+ Timer.run(_readHandler); |
} |
if (_socketClosedRead) { // An onClose event is pending. |
@@ -446,7 +446,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
if (_filterReadEmpty) { |
// This can't be an else clause: the value of _filterReadEmpty changes. |
// This must be asynchronous, because we are in a read call. |
- new Timer(0, (_) => _closeHandler()); |
+ Timer.run(_closeHandler); |
} |
} |
@@ -532,7 +532,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
} |
if (_socketClosedRead) { |
// Keep firing read events until we are paused or buffer is empty. |
- new Timer(0, (_) => _readHandler()); |
+ Timer.run(_readHandler); |
} |
} |
} else if (_socketClosedRead) { |
@@ -602,7 +602,7 @@ class _RawSecureSocket extends Stream<RawSocketEvent> |
// If we complete the future synchronously, user code will run here, |
// and modify the state of the RawSecureSocket. For example, it |
// could close the socket, and set _filter to null. |
- new Timer(0, (_) => _handshakeComplete.complete(this)); |
+ Timer.run(() => _handshakeComplete.complete(this)); |
} |
} |