pipestop

like stream.pipe(), but stoppable

Sadly, this package has no readme. Go write one!