Readable stream that ensures that onend is only called once no ondata items are pending, thus supporting async operations inside ondata.