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

flatMapLatestAndMerge

@JvmName(name = "flatMapLatestAndMergeSet")
fun <V : Any, R> Flow<Set<V>>.flatMapLatestAndMerge(entryEventTransformer: (SetEvent.EntryEvent<V>) -> Flow<R>): Flow<R>(source)
fun <V : Any, R> Flow<SetEvent<V>>.flatMapLatestAndMerge(entryEventTransformer: (SetEvent.EntryEvent<V>) -> Flow<R>): Flow<R>(source)