StreamExtension<T> extension

on

Methods

asFlow(T initialValue) Flow<T>
Create a flow that listens for updates from this stream. Requires an initial value. Only emits successful values from the stream.