anchor.diff:          if (!topicsToReset.containsKey(result.topicName)) {
             topicsToReset[result.topicName] = [];
           }
  -        topicsToReset[result].add(result.partitionId);
  +        topicsToReset[result.topicName].add(result.partitionId);
         }
       }
   
  
positive.code:           }
          });
        });
      });
  
      return controller.stream;
  
negative.code:       return true;
      }
      return false;
    }
  
    void addError(Object error, [StackTrace stackTrace]) {
      _controller.addError(error, stackTrace);
    }
  
    void cancel() {
  