FlowMergeArray

@FlowPreview()
class FlowMergeArray<T>(sources: Array<out Flow<T>>) : AbstractFlow<T>
Content copied to clipboard

Merges an array of Flow instances in an unbounded manner.

Parameters

the shared element type
prefetch

the number of items to allow through from each source before suspending

Constructors

FlowMergeArray
Link copied to clipboard
fun <T> FlowMergeArray(sources: Array<out Flow<T>>)
Content copied to clipboard
the shared element type

Functions

collect
Link copied to clipboard
suspend override fun collect(collector: FlowCollector<T>)
Content copied to clipboard
collectSafely
Link copied to clipboard
open suspend override fun collectSafely(collector: FlowCollector<T>)
Content copied to clipboard