Utility extensions on Stream.

on

• Stream<T>

Properties

firstOrNull → Future<T?>

A future which completes with the first event of this stream, or with null.

no setter

Methods

listenAndBuffer() → Stream<T>

Eagerly listens to this stream and buffers events until needed.

slices(int length) → Stream<List<T>>

Creates a stream whose elements are contiguous slices of this.