OfflineSyncStreamEventStreamExtension extension

Extensions for stream iterators of OfflineSyncStreamEvent.

on

Methods

collectNextBatch({bool allowCloseBeforeBatch = false}) → Future<OfflineSyncCycleBatch?>

Available on StreamIterator<OfflineSyncStreamEvent>, provided by the OfflineSyncStreamEventStreamExtension extension

Collects the next framed sync batch from this iterator.
moveAndThrowIfNot<T extends OfflineSyncStreamEvent>() → Future<T>

Available on StreamIterator<OfflineSyncStreamEvent>, provided by the OfflineSyncStreamEventStreamExtension extension

Moves the iterator to the next event and throws if the stream is closed or the next event is not of type T.