anchor.diff:    /// The future completed when the correct number of events have been captured.
     Future get future => _completer.future;
   
  -  bool addEvents(Queue<Events> events) {
  +  bool addEvents(Queue<Result> events) {
       while (_list.length < _eventsToTake) {
         if (events.isEmpty) return false;
         var result = events.removeFirst();
  
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:     return true;
    }
  
    void close(Queue<Result> events) {
      _completer.complete(_list);
    }
  }
  