| Index: sdk/lib/async/stream.dart
|
| diff --git a/sdk/lib/async/stream.dart b/sdk/lib/async/stream.dart
|
| index a026484e214758b66f11b97c3de55af19a00ca49..dddc00406cc5ba3a970226010fdd988f5cd4df4f 100644
|
| --- a/sdk/lib/async/stream.dart
|
| +++ b/sdk/lib/async/stream.dart
|
| @@ -77,7 +77,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Whether the stream is a broadcast stream.
|
| + * Reports whether this stream is a broadcast stream.
|
| */
|
| bool get isBroadcast => false;
|
|
|
| @@ -97,9 +97,9 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Add a subscription to this stream.
|
| + * Adds a subscription to this stream.
|
| *
|
| - * On each data event from this stream, the subscribers [onData] handler
|
| + * On each data event from this stream, the subscriber's [onData] handler
|
| * is called. If [onData] is null, nothing happens.
|
| *
|
| * On errors from this stream, the [onError] handler is given a
|
| @@ -126,7 +126,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Create a new stream that converts each element of this stream
|
| + * Creates a new stream that converts each element of this stream
|
| * to a new value using the [convert] function.
|
| */
|
| Stream map(convert(T event)) {
|
| @@ -134,7 +134,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Create a wrapper Stream that intercepts some errors from this stream.
|
| + * Creates a wrapper Stream that intercepts some errors from this stream.
|
| *
|
| * If this stream sends an error that matches [test], then it is intercepted
|
| * by the [handle] function.
|
| @@ -155,7 +155,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Create a new stream from this stream that converts each element
|
| + * Creates a new stream from this stream that converts each element
|
| * into zero or more events.
|
| *
|
| * Each incoming event is converted to an [Iterable] of new events,
|
| @@ -167,14 +167,14 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Bind this stream as the input of the provided [StreamConsumer].
|
| + * Binds this stream as the input of the provided [StreamConsumer].
|
| */
|
| Future pipe(StreamConsumer<T, dynamic> streamConsumer) {
|
| return streamConsumer.consume(this);
|
| }
|
|
|
| /**
|
| - * Chain this stream as the input of the provided [StreamTransformer].
|
| + * Chains this stream as the input of the provided [StreamTransformer].
|
| *
|
| * Returns the result of [:streamTransformer.bind:] itself.
|
| */
|
| @@ -225,7 +225,7 @@ abstract class Stream<T> {
|
|
|
|
|
| /**
|
| - * Check whether [match] occurs in the elements provided by this stream.
|
| + * Checks whether [match] occurs in the elements provided by this stream.
|
| *
|
| * Completes the [Future] when the answer is known.
|
| * If this stream reports an error, the [Future] will report that error.
|
| @@ -257,7 +257,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Check whether [test] accepts all elements provided by this stream.
|
| + * Checks whether [test] accepts all elements provided by this stream.
|
| *
|
| * Completes the [Future] when the answer is known.
|
| * If this stream reports an error, the [Future] will report that error.
|
| @@ -289,7 +289,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Check whether [test] accepts any element provided by this stream.
|
| + * Checks whether [test] accepts any element provided by this stream.
|
| *
|
| * Completes the [Future] when the answer is known.
|
| * If this stream reports an error, the [Future] will report that error.
|
| @@ -440,7 +440,7 @@ abstract class Stream<T> {
|
| return future;
|
| }
|
|
|
| - /** Collect the data of this stream in a [List]. */
|
| + /** Collects the data of this stream in a [List]. */
|
| Future<List<T>> toList() {
|
| List<T> result = <T>[];
|
| _FutureImpl<List<T>> future = new _FutureImpl<List<T>>();
|
| @@ -458,7 +458,7 @@ abstract class Stream<T> {
|
| return future;
|
| }
|
|
|
| - /** Collect the data of this stream in a [Set]. */
|
| + /** Collects the data of this stream in a [Set]. */
|
| Future<Set<T>> toSet() {
|
| Set<T> result = new Set<T>();
|
| _FutureImpl<Set<T>> future = new _FutureImpl<Set<T>>();
|
| @@ -477,7 +477,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Provide at most the first [n] values of this stream.
|
| + * Provides at most the first [n] values of this stream.
|
| *
|
| * Forwards the first [n] data events of this stream, and all error
|
| * events, to the returned stream, and ends with a done event.
|
| @@ -521,7 +521,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Skip data events if they are equal to the previous data event.
|
| + * Skips data events if they are equal to the previous data event.
|
| *
|
| * The returned stream provides the same events as this stream, except
|
| * that it never provides two consequtive data events that are equal.
|
| @@ -624,7 +624,7 @@ abstract class Stream<T> {
|
| }
|
|
|
| /**
|
| - * Find the first element of this stream matching [test].
|
| + * Finds the first element of this stream matching [test].
|
| *
|
| * Returns a future that is filled with the first element of this stream
|
| * that [test] returns true for.
|
|
|