var through = require('through')
  , disconnect = require('disconnect-stream')
  , source = through()
  , dest = through()
 
source.pipe(dest)
 
dest.on('data', function() {
  console.log('got data')
})
 
source.write('data') // "got data"
 
disconnect(source) // returns `true` since there were dest pipes
 
source.write('data')
 
source.readable && source.writable // true
dest.readable && dest.writable // true