Blocks until all available data in the source has been processed and committed to the
sink. This method is intended for testing.
New in version 2.0.0.
In the case of continually arriving data, this method may block forever.
Additionally, this method is only guaranteed to block until data that has been
synchronously appended data to a stream source prior to invocation.
(i.e. getOffset must immediately reflect the addition).