only need self.push({}) to work
oops
isolates
working title
need readable stream to end
finally working
don't need finished
throw new Error
new functionality
works with no pipes
don't need to close upstream
don't need to close upstream
fix possible race condition
fix possible race condition
simpler part working
example cleaning
mistake
listen when there is probably no listener
remove isolations
not good