var paused = true
    var ts = through(function () {
         console.log('paused?', paused)
     }).pause()

     fs.createReadStream('foobar').pipe(ts)

     setTimeout(function () {
         paused = false
         ts.resume()
     }, 1000)