| OLD | NEW |
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 part of dart.async; | 5 part of dart.async; |
| 6 | 6 |
| 7 /** The onValue and onError handlers return either a value or a future */ | 7 /** The onValue and onError handlers return either a value or a future */ |
| 8 typedef dynamic _FutureOnValue<T>(T value); | 8 typedef dynamic _FutureOnValue<T>(T value); |
| 9 /** Test used by [Future.catchError] to handle skip some errors. */ | 9 /** Test used by [Future.catchError] to handle skip some errors. */ |
| 10 typedef bool _FutureErrorTest(var error); | 10 typedef bool _FutureErrorTest(var error); |
| (...skipping 607 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 618 result._setValue(listenerValueOrError); | 618 result._setValue(listenerValueOrError); |
| 619 } else { | 619 } else { |
| 620 AsyncError asyncError = listenerValueOrError; | 620 AsyncError asyncError = listenerValueOrError; |
| 621 result._setErrorObject(asyncError); | 621 result._setErrorObject(asyncError); |
| 622 } | 622 } |
| 623 // Prepare for next round. | 623 // Prepare for next round. |
| 624 source = result; | 624 source = result; |
| 625 } | 625 } |
| 626 } | 626 } |
| 627 | 627 |
| 628 Future timeout(Duration timeLimit, {onTimeout()}) { | 628 Future<T> timeout(Duration timeLimit, {onTimeout()}) { |
| 629 if (_isComplete) return new _Future.immediate(this); | 629 if (_isComplete) return new _Future.immediate(this); |
| 630 _Future result = new _Future(); | 630 _Future result = new _Future<T>(); |
| 631 Timer timer; | 631 Timer timer; |
| 632 if (onTimeout == null) { | 632 if (onTimeout == null) { |
| 633 timer = new Timer(timeLimit, () { | 633 timer = new Timer(timeLimit, () { |
| 634 result._completeError(new TimeoutException("Future not completed", | 634 result._completeError(new TimeoutException("Future not completed", |
| 635 timeLimit)); | 635 timeLimit)); |
| 636 }); | 636 }); |
| 637 } else { | 637 } else { |
| 638 Zone zone = Zone.current; | 638 Zone zone = Zone.current; |
| 639 onTimeout = zone.registerCallback(onTimeout); | 639 onTimeout = zone.registerCallback(onTimeout); |
| 640 timer = new Timer(timeLimit, () { | 640 timer = new Timer(timeLimit, () { |
| (...skipping 11 matching lines...) Expand all Loading... |
| 652 } | 652 } |
| 653 }, onError: (e, s) { | 653 }, onError: (e, s) { |
| 654 if (timer.isActive) { | 654 if (timer.isActive) { |
| 655 timer.cancel(); | 655 timer.cancel(); |
| 656 result._completeError(e, s); | 656 result._completeError(e, s); |
| 657 } | 657 } |
| 658 }); | 658 }); |
| 659 return result; | 659 return result; |
| 660 } | 660 } |
| 661 } | 661 } |
| OLD | NEW |