Add a `flush` method to the stream

[liammclennan]

Add a method that returns a promise that resolves when events have been flushed all the way through to Seq.