anchor.diff:    /**
      * The number of elements in this stream.
      *
  -   * Waits for all elements of this stream. When the stream ends,
  +   * Waits for all elements of this stream. When this stream ends,
      * the returned future is completed with the number of elements.
      *
  -   * If the stream contains an error, the returned future is completed with
  -   * that error, and processing stops.
  -   *
  -   * This operation listens to the stream, and a non-broadcast stream cannot
  +   * If this stream emits an error,
  +   * the returned future is completed with that error,
  +   * and processing stops.
  +   *
  +   * This operation listens to this stream, and a non-broadcast stream cannot
      * be reused after finding its length.
      */
     Future<int> get length {
  
positive.code:   /**
     * Collects all elements of this stream in a [List].
     *
     * Creates a `List<T>` and adds all elements of the stream to the list
     * in the order they arrive.
     * When the stream ends, the returned future is completed with that list.
     *
     * If the stream contains an error, the returned future is completed
     * with that error, and processing stops.
     */
    Future<List<T>> toList() {
      List<T> result = <T>[];
  
negative.code:   /**
     * Adds a subscription to this stream.
     *
     * Returns a [StreamSubscription] which handles events from this stream using
     * the provided [onData], [onError] and [onDone] handlers.
     * The handlers can be changed on the subscription, but they start out
     * as the provided functions.
  