flush method
Waits until accepted entries reach their destination (for example are persisted to the store) without closing the sink (onFlush). After close, waits for the closing to complete, which delivers everything accepted.
Implementation
@nonVirtual
Future<void> flush() => _closing ?? Future.sync(onFlush);