Index: sdk/lib/io/stream_util.dart |
diff --git a/sdk/lib/io/stream_util.dart b/sdk/lib/io/stream_util.dart |
index 150018168750a46856a01442e6ba2adf73e12abc..f111a6401035baa10f697f2d75c0fce100cd60a2 100644 |
--- a/sdk/lib/io/stream_util.dart |
+++ b/sdk/lib/io/stream_util.dart |
@@ -12,7 +12,7 @@ abstract class _BaseDataInputStream { |
_checkScheduleCallbacks(); |
return null; |
} |
- if (len !== null) { |
+ if (len != null) { |
if (len <= 0) { |
throw new StreamException("Illegal length $len"); |
} else if (bytesToRead > len) { |
@@ -24,7 +24,7 @@ abstract class _BaseDataInputStream { |
int readInto(List<int> buffer, [int offset = 0, int len]) { |
if (_closeCallbackCalled || _scheduledCloseCallback != null) return 0; |
- if (len === null) len = buffer.length; |
+ if (len == null) len = buffer.length; |
if (offset < 0) throw new StreamException("Illegal offset $offset"); |
if (len < 0) throw new StreamException("Illegal length $len"); |
int bytesToRead = min(len, available()); |
@@ -71,7 +71,7 @@ abstract class _BaseDataInputStream { |
// More data has been received asynchronously. Perform the data |
// handler callback now. |
_cancelScheduledDataCallback(); |
- if (_clientDataHandler !== null) { |
+ if (_clientDataHandler != null) { |
_clientDataHandler(); |
} |
_checkScheduleCallbacks(); |
@@ -83,7 +83,7 @@ abstract class _BaseDataInputStream { |
_streamMarkedClosed = true; |
if (available() == 0) { |
_closeCallbackCalled = true; |
- if (_clientCloseHandler !== null) _clientCloseHandler(); |
+ if (_clientCloseHandler != null) _clientCloseHandler(); |
} else { |
_checkScheduleCallbacks(); |
} |
@@ -99,7 +99,7 @@ abstract class _BaseDataInputStream { |
void _checkScheduleCallbacks() { |
void issueDataCallback(Timer timer) { |
_scheduledDataCallback = null; |
- if (_clientDataHandler !== null) { |
+ if (_clientDataHandler != null) { |
_clientDataHandler(); |
_checkScheduleCallbacks(); |
} |
@@ -108,7 +108,7 @@ abstract class _BaseDataInputStream { |
void issueCloseCallback(Timer timer) { |
_scheduledCloseCallback = null; |
_closeCallbackCalled = true; |
- if (_clientCloseHandler !== null) _clientCloseHandler(); |
+ if (_clientCloseHandler != null) _clientCloseHandler(); |
} |
// Schedule data callback if there is more data to read. Schedule |
@@ -154,7 +154,7 @@ void _pipe(InputStream input, OutputStream output, {bool close}) { |
pipeDataHandler = () { |
List<int> data; |
- while ((data = input.read()) !== null) { |
+ while ((data = input.read()) != null) { |
if (!output.write(data)) { |
input.onData = null; |
output.onNoPendingWrites = pipeNoPendingWriteHandler; |
@@ -165,7 +165,7 @@ void _pipe(InputStream input, OutputStream output, {bool close}) { |
pipeCloseHandler = () { |
if (close) output.close(); |
- if (_inputCloseHandler !== null) { |
+ if (_inputCloseHandler != null) { |
_inputCloseHandler(); |
} |
}; |