code: function(e){
              // detach finish listener!
              if (ostream){
                  ostream.removeListener('finish', onComplete);
              }
              
              // close streams
              if (istream){
                  istream.destroy();
              }
              if (ostream){
                  ostream.end();
              }
  
              // throw error
              reject(e);
          }
docs: cleanup