anchor.diff:      return true;
     }
   
  -  void close(Queue<Events> events) {
  +  void close(Queue<Result> events) {
       _completer.complete(_list);
     }
   }
  
positive.code: ///
  /// The [close] method is also called immediately when the source stream
  /// is done.
  abstract class _EventRequest implements EventSink {
    /// Handle available events.
    ///
    /// The available events are provided as a queue. The `addEvents` function
  
negative.code:   /// Ensures that we are listening on events from [_sourceStream].
    ///
    /// Resumes subscription on [_sourceStream], or creates it if necessary.
    void _ensureListening() {
      assert(!_isDone);
      if (_subscription == null) {
        _subscription =
  