kmath
0.3.1-dev-RC
common
kmath-coroutines
/
space.kscience.kmath.coroutines
/
collect
collect
suspend
fun
<
T
>
AsyncFlow
<
T
>
.
collect
(
concurrency
:
Int
,
collector
:
FlowCollector
<
T
>
)
(
source
)
inline suspend
fun
<
T
>
AsyncFlow
<
T
>
.
collect
(
concurrency
:
Int
,
crossinline
action
:
suspend
(
value
:
T
)
->
Unit
)
(
source
)