anchor.diff:      return _newStreamWrapper(stream.timeout(timeLimit, onTimeout: onTimeout));
     }
   
  -  /** Collects the data of this stream in a [List]. */
  +  /// Collects the data of this stream in a [List].
     @override
     Future<List<T>> toList() {
       return stream.toList();
  
positive.code:     return stream.firstWhere(test, defaultValue: defaultValue);
    }
  
    /** Reduces a sequence of values by repeatedly applying [combine]. */
    @override
    Future fold(initialValue, combine(previous, T element)) {
      return stream.fold(initialValue, combine);
  
negative.code:     return stream.lastWhere(test, defaultValue: defaultValue);
    }
  
    /// Counts the elements in the stream.
    @override
    Future<int> get length => stream.length;
  
  