Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(158)

Side by Side Diff: pkg/analyzer/lib/src/cancelable_future.dart

Issue 2669603004: Fix bot breakage (TBR) (Closed)
Patch Set: Created 3 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2014, 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 analyzer.src.cancelable_future; 5 library analyzer.src.cancelable_future;
6 6
7 import 'dart:async'; 7 import 'dart:async';
8 8
9 /** 9 /**
10 * Type of callback called when the future returned by a CancelableCompleter 10 * Type of callback called when the future returned by a CancelableCompleter
(...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after
245 @override 245 @override
246 void cancel() { 246 void cancel() {
247 _completer._cancel(); 247 _completer._cancel();
248 } 248 }
249 249
250 @override 250 @override
251 Future<T> catchError(Function onError, {bool test(Object error)}) => 251 Future<T> catchError(Function onError, {bool test(Object error)}) =>
252 _completer._outerCompleter.future.catchError(onError, test: test); 252 _completer._outerCompleter.future.catchError(onError, test: test);
253 253
254 @override 254 @override
255 Future/*<S>*/ then/*<S>*/(FutureOr<S> onValue(T value), {Function onError}) => 255 Future/*<S>*/ then/*<S>*/(FutureOr/*<S>*/ onValue(T value),
256 {Function onError}) =>
256 _completer._outerCompleter.future.then(onValue, onError: onError); 257 _completer._outerCompleter.future.then(onValue, onError: onError);
257 258
258 @override 259 @override
259 Future<T> timeout(Duration timeLimit, {onTimeout()}) { 260 Future<T> timeout(Duration timeLimit, {onTimeout()}) {
260 // TODO(paulberry): Implement this in such a way that a timeout cancels 261 // TODO(paulberry): Implement this in such a way that a timeout cancels
261 // the future. 262 // the future.
262 return _completer._outerCompleter.future 263 return _completer._outerCompleter.future
263 .timeout(timeLimit, onTimeout: onTimeout); 264 .timeout(timeLimit, onTimeout: onTimeout);
264 } 265 }
265 266
(...skipping 15 matching lines...) Expand all
281 Stream<T> asStream() => _future.asStream(); 282 Stream<T> asStream() => _future.asStream();
282 283
283 @override 284 @override
284 void cancel() {} 285 void cancel() {}
285 286
286 @override 287 @override
287 Future<T> catchError(Function onError, {bool test(Object error)}) => 288 Future<T> catchError(Function onError, {bool test(Object error)}) =>
288 _future.catchError(onError, test: test); 289 _future.catchError(onError, test: test);
289 290
290 @override 291 @override
291 Future/*<S>*/ then/*<S>*/(FutureOr<S> onValue(T value), {Function onError}) => 292 Future/*<S>*/ then/*<S>*/(FutureOr/*<S>*/ onValue(T value),
293 {Function onError}) =>
292 _future.then(onValue, onError: onError); 294 _future.then(onValue, onError: onError);
293 295
294 @override 296 @override
295 Future<T> timeout(Duration timeLimit, {onTimeout()}) => 297 Future<T> timeout(Duration timeLimit, {onTimeout()}) =>
296 _future.timeout(timeLimit, onTimeout: onTimeout); 298 _future.timeout(timeLimit, onTimeout: onTimeout);
297 299
298 @override 300 @override
299 Future<T> whenComplete(action()) => _future.whenComplete(action); 301 Future<T> whenComplete(action()) => _future.whenComplete(action);
300 } 302 }
OLDNEW
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698