anchor.diff:      this.end();
       this.done.then((n){
         this._streams.free();
  -      this._handler = this._backhandler = null;
  +      this._handler = this._backhandler = this._drain = null;
       });
     }
     
  
positive.code:     (!this.paused ? this._handler = n : this._backhandler = n);
      (this.paused ? this.resume() : this.push());
    }
  
    void disconnect(){
      this._handler = this._backhandler = null;
    }
  
negative.code: 
  class BufferedStream<T> extends Streamer<T>{
    final Streamable stream = new Streamable<T>();
    final Streamable _buffer = new Streamable<T>();
    bool _draining = false;
    
    static create() => new BufferedStream();
  
    BufferedStream(){
        this._buffer.pause();
  	  this._buffer.onDrain((){
  		  this._buffer.pause();
  	  });
    }
  
    void resume(){
      this.stream.resume();
  