datasourcex-util/com.caplin.integration.datasourcex.util.flow/materialize

materialize

fun <T> Flow<T>.materialize(): Flow<ValueOrCompletion<T>>(source)

Materialize Flow events into ValueOrCompletions that can be sent over the wire, for example.