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

Side by Side Diff: lib/src/delegate/stream_consumer.dart

Issue 2660333005: Change generic comment syntax to real generic syntax. (Closed)
Patch Set: Update version. 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 | « lib/src/delegate/stream.dart ('k') | lib/src/delegate/stream_sink.dart » ('j') | 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) 2015, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2015, 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 import 'dart:async'; 5 import 'dart:async';
6 6
7 /// Simple delegating wrapper around a [StreamConsumer]. 7 /// Simple delegating wrapper around a [StreamConsumer].
8 /// 8 ///
9 /// Subclasses can override individual methods, or use this to expose only the 9 /// Subclasses can override individual methods, or use this to expose only the
10 /// [StreamConsumer] methods of a subclass. 10 /// [StreamConsumer] methods of a subclass.
11 class DelegatingStreamConsumer<T> implements StreamConsumer<T> { 11 class DelegatingStreamConsumer<T> implements StreamConsumer<T> {
12 final StreamConsumer _consumer; 12 final StreamConsumer _consumer;
13 13
14 /// Create a delegating consumer forwarding calls to [consumer]. 14 /// Create a delegating consumer forwarding calls to [consumer].
15 DelegatingStreamConsumer(StreamConsumer<T> consumer) : _consumer = consumer; 15 DelegatingStreamConsumer(StreamConsumer<T> consumer) : _consumer = consumer;
16 16
17 DelegatingStreamConsumer._(this._consumer); 17 DelegatingStreamConsumer._(this._consumer);
18 18
19 /// Creates a wrapper that coerces the type of [consumer]. 19 /// Creates a wrapper that coerces the type of [consumer].
20 /// 20 ///
21 /// Unlike [new StreamConsumer], this only requires its argument to be an 21 /// Unlike [new StreamConsumer], this only requires its argument to be an
22 /// instance of `StreamConsumer`, not `StreamConsumer<T>`. This means that 22 /// instance of `StreamConsumer`, not `StreamConsumer<T>`. This means that
23 /// calls to [addStream] may throw a [CastError] if the argument type doesn't 23 /// calls to [addStream] may throw a [CastError] if the argument type doesn't
24 /// match the reified type of [consumer]. 24 /// match the reified type of [consumer].
25 static StreamConsumer/*<T>*/ typed/*<T>*/(StreamConsumer consumer) => 25 static StreamConsumer<T> typed<T>(StreamConsumer consumer) =>
26 consumer is StreamConsumer/*<T>*/ 26 consumer is StreamConsumer<T>
27 ? consumer 27 ? consumer
28 : new DelegatingStreamConsumer._(consumer); 28 : new DelegatingStreamConsumer._(consumer);
29 29
30 Future addStream(Stream<T> stream) => _consumer.addStream(stream); 30 Future addStream(Stream<T> stream) => _consumer.addStream(stream);
31 31
32 Future close() => _consumer.close(); 32 Future close() => _consumer.close();
33 } 33 }
OLDNEW
« no previous file with comments | « lib/src/delegate/stream.dart ('k') | lib/src/delegate/stream_sink.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698