| Index: sdk/lib/async/stream_impl.dart
|
| diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart
|
| index 0133f68128c9d49de29dfbf3d31ce2cf73fe0c8b..20314c88a17d5170ab621f7ea4ce5d5ce4a46823 100644
|
| --- a/sdk/lib/async/stream_impl.dart
|
| +++ b/sdk/lib/async/stream_impl.dart
|
| @@ -354,10 +354,7 @@ class _BufferingStreamSubscription<T> implements StreamSubscription<T>,
|
| // future to finish we must not report the error.
|
| if (_isCanceled && !_waitsForCancel) return;
|
| _state |= _STATE_IN_CALLBACK;
|
| - if (!_zone.inSameErrorZone(Zone.current)) {
|
| - // Errors are not allowed to traverse zone boundaries.
|
| - Zone.current.handleUncaughtError(error, stackTrace);
|
| - } else if (_onError is ZoneBinaryCallback) {
|
| + if (_onError is ZoneBinaryCallback) {
|
| _zone.runBinaryGuarded(_onError, error, stackTrace);
|
| } else {
|
| _zone.runUnaryGuarded(_onError, error);
|
|
|