| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 library schedule; | 5 library schedule; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:collection'; | 8 import 'dart:collection'; |
| 9 | 9 |
| 10 import 'package:unittest/unittest.dart' as unittest; | 10 import 'package:unittest/unittest.dart' as unittest; |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 88 /// to 30 seconds. This can be set to `null` to disable timeouts entirely. | 88 /// to 30 seconds. This can be set to `null` to disable timeouts entirely. |
| 89 /// | 89 /// |
| 90 /// If a task queue times out, an error will be raised that can be handled as | 90 /// If a task queue times out, an error will be raised that can be handled as |
| 91 /// usual in the [onException] and [onComplete] queues. If [onException] times | 91 /// usual in the [onException] and [onComplete] queues. If [onException] times |
| 92 /// out, that can only be handled in [onComplete]; if [onComplete] times out, | 92 /// out, that can only be handled in [onComplete]; if [onComplete] times out, |
| 93 /// that cannot be handled. | 93 /// that cannot be handled. |
| 94 /// | 94 /// |
| 95 /// If a task times out and then later completes with an error, that error | 95 /// If a task times out and then later completes with an error, that error |
| 96 /// cannot be handled. The user will still be notified of it. | 96 /// cannot be handled. The user will still be notified of it. |
| 97 Duration get timeout => _timeout; | 97 Duration get timeout => _timeout; |
| 98 Duration _timeout = new Duration(seconds: 2); | 98 Duration _timeout = new Duration(seconds: 30); |
| 99 set timeout(Duration duration) { | 99 set timeout(Duration duration) { |
| 100 _timeout = duration; | 100 _timeout = duration; |
| 101 heartbeat(); | 101 heartbeat(); |
| 102 } | 102 } |
| 103 | 103 |
| 104 /// The number of out-of-band callbacks that have been registered with | 104 /// The number of out-of-band callbacks that have been registered with |
| 105 /// [wrapAsync] but have yet to be called. | 105 /// [wrapAsync] but have yet to be called. |
| 106 int _pendingCallbacks = 0; | 106 int _pendingCallbacks = 0; |
| 107 | 107 |
| 108 /// A completer that will be completed once [_pendingCallbacks] reaches zero. | 108 /// A completer that will be completed once [_pendingCallbacks] reaches zero. |
| (...skipping 408 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 517 return _contents.map((task) { | 517 return _contents.map((task) { |
| 518 var lines = task.toString().split("\n"); | 518 var lines = task.toString().split("\n"); |
| 519 var firstLine = task == highlight ? | 519 var firstLine = task == highlight ? |
| 520 "> ${lines.first}" : "* ${lines.first}"; | 520 "> ${lines.first}" : "* ${lines.first}"; |
| 521 lines = new List.from(lines.skip(1).map((line) => "| $line")); | 521 lines = new List.from(lines.skip(1).map((line) => "| $line")); |
| 522 lines.insertRange(0, 1, firstLine); | 522 lines.insertRange(0, 1, firstLine); |
| 523 return lines.join("\n"); | 523 return lines.join("\n"); |
| 524 }).join("\n"); | 524 }).join("\n"); |
| 525 } | 525 } |
| 526 } | 526 } |
| OLD | NEW |