Home
last modified time | relevance | path

Searched defs:asFlow (Results 1 – 10 of 10) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DBuilders.kt68 public fun <T> (() -> T).asFlow(): Flow<T> = flow { in <lambda>() method
82 public fun <T> (suspend () -> T).asFlow(): Flow<T> = flow { in <lambda>() method
89 public fun <T> Iterable<T>.asFlow(): Flow<T> = flow { in <lambda>() method
98 public fun <T> Iterator<T>.asFlow(): Flow<T> = flow { in <lambda>() method
107 public fun <T> Sequence<T>.asFlow(): Flow<T> = flow { in <lambda>() method
153 public fun <T> Array<T>.asFlow(): Flow<T> = flow { in <lambda>() method
164 public fun IntArray.asFlow(): Flow<Int> = flow { in <lambda>() method
175 public fun LongArray.asFlow(): Flow<Long> = flow { in <lambda>() method
184 public fun IntRange.asFlow(): Flow<Int> = flow { in <lambda>() method
193 public fun LongRange.asFlow(): Flow<Long> = flow { in <lambda>() method
DChannels.kt153 public fun <T> BroadcastChannel<T>.asFlow(): Flow<T> = flow { in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DMigration.kt38 public fun <T : Any> Publisher<T>.asFlow(batchSize: Int): Flow<T> = asFlow().buffer(batchSize) method
DReactiveFlow.kt30 public fun <T : Any> Publisher<T>.asFlow(): Flow<T> = in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/
DReactiveFlow.kt26 public fun <T : Any> JFlow.Publisher<T>.asFlow(): Flow<T> = method
/external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/
DJavaFxConvert.kt27 public fun <T> ObservableValue<T>.asFlow(): Flow<T> = callbackFlow<T> { in <lambda>() method
/external/mesa3d/src/gallium/drivers/nouveau/codegen/
Dnv50_ir_inlines.h298 FlowInstruction *Instruction::asFlow() in asFlow() function
305 const FlowInstruction *Instruction::asFlow() const in asFlow() function
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxConvert.kt75 public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow { in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxConvert.kt75 public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow { in <lambda>() method
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/scrabble/
DFlowPlaysScrabbleOpt.kt118 public fun String.asFlow() = flow { in <lambda>() method
124 public fun String.asFlow(startIndex: Int = 0, endIndex: Int = length) = in asFlow() method