original_string: public function pipe($dest)
      {
          $source              = $this;
          $this->onMessage     = function ($source, $data) use ($dest) {
              $dest->send($data);
          };
          $this->onClose       = function ($source) use ($dest) {
              $dest->destroy();
          };
          $dest->onBufferFull  = function ($dest) use ($source) {
              $source->pauseRecv();
          };
          $dest->onBufferDrain = function ($dest) use ($source) {
              $source->resumeRecv();
          };
      }
code: public function pipe($dest)
      {
          $source              = $this;
          $this->onMessage     = function ($source, $data) use ($dest) {
              $dest->send($data);
          };
          $this->onClose       = function ($source) use ($dest) {
              $dest->destroy();
          };
          $dest->onBufferFull  = function ($dest) use ($source) {
              $source->pauseRecv();
          };
          $dest->onBufferDrain = function ($dest) use ($source) {
              $source->resumeRecv();
          };
      }
code_tokens: public function pipe ( $ dest ) { $ source = $ this ; $ this -> onMessage = function ( $ source , $ data ) use ( $ dest ) { $ dest -> send ( $ data ) ; } ; $ this -> onClose = function ( $ source ) use ( $ dest ) { $ dest -> destroy ( ) ; } ; $ dest -> onBufferFull = function ( $ dest ) use ( $ source ) { $ source -> pauseRecv ( ) ; } ; $ dest -> onBufferDrain = function ( $ dest ) use ( $ source ) { $ source -> resumeRecv ( ) ; } ; }
docstring: This method pulls all the data out of a readable stream, and writes it to the supplied destination.
  
  @param TcpConnection $dest
  @return void
docstring_tokens: This method pulls all the data out of a readable stream and writes it to the supplied destination .