Index: sdk/lib/async/stream.dart |
diff --git a/sdk/lib/async/stream.dart b/sdk/lib/async/stream.dart |
index 64a525f1f30dcd6d7ae258c35bc761661c8f4ab5..ba5b25cbd20b7f6c2b6fb9d5998cb349fd1c2bf2 100644 |
--- a/sdk/lib/async/stream.dart |
+++ b/sdk/lib/async/stream.dart |
@@ -390,8 +390,8 @@ abstract class Stream<T> { |
/// |
/// A key is extracted from incoming events. |
/// The first time a key is seen, a stream is created for it, and emitted |
- /// on the returned stream, along with the key, as a [StreamGroup] object. |
- /// Then the event is emitted on the stream ([StreamGroup.values]) |
+ /// on the returned stream, along with the key, as a [GroupedEvents] object. |
+ /// Then the event is emitted on the stream ([GroupedEvents.values]) |
/// corresponding to the key. |
/// |
/// An error on the source stream, or when calling the `key` functions, |
@@ -406,11 +406,11 @@ abstract class Stream<T> { |
/// Pausing or canceling an individual group stream has no effect other than |
/// on that stream. Events will be queued while the group stream |
/// is paused and until it is first listened to. |
- /// If the [StreamGroup.values] stream is never listened to, |
+ /// If the [GroupedEvents.values] stream is never listened to, |
/// it will enqueue all the events unnecessarily. |
- Stream<StreamGroup<K, T>> groupBy<K>(K key(T event)) { |
+ Stream<GroupedEvents<K, T>> groupBy<K>(K key(T event)) { |
var controller; |
- controller = new StreamController<StreamGroup<K, T>>( |
+ controller = new StreamController<GroupedEvents<K, T>>( |
sync: true, |
onListen: () { |
var groupControllers = new HashMap<K, StreamController<T>>(); |
@@ -436,7 +436,7 @@ abstract class Stream<T> { |
new StreamController<T>.broadcast(sync: true); |
groupControllers[theKey] = groupController; |
controller.add( |
- new StreamGroup<K, T>(theKey, groupController.stream)); |
+ new GroupedEvents<K, T>(theKey, groupController.stream)); |
} |
groupController.add(data); |
}, |
@@ -1909,23 +1909,23 @@ class _ControllerEventSinkWrapper<T> implements EventSink<T> { |
/// A group created by [Stream.groupBy] or [Stream.groupByMapped]. |
/// |
-/// The stream created by `groupBy` emits a `StreamGroup` for each distinct key |
+/// The stream created by `groupBy` emits a `GroupedEvents` for each distinct key |
/// it encounters. |
/// This group contains the [key] itself, along with a stream of the [values] |
/// associated with that key. |
-class StreamGroup<K, V> { |
+class GroupedEvents<K, V> { |
/// The key that identifiers the values emitted by [values]. |
final K key; |
/// The [values] that [GroupBy] have grouped by the common [key]. |
final Stream<V> values; |
- factory StreamGroup(K key, Stream<V> values) = StreamGroup<K, V>._; |
+ factory GroupedEvents(K key, Stream<V> values) = GroupedEvents<K, V>._; |
// Don't expose a generative constructor. |
// This class is not intended for subclassing, so we don't want to promise |
// it. We can change that in the future. |
- StreamGroup._(this.key, this.values); |
+ GroupedEvents._(this.key, this.values); |
/// Tells [values] to discard values instead of retaining them. |
/// |