Revert a change that didn't work - the stream doesn't emit 'end' after it's done with each bundle