Home
last modified time | relevance | path

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

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DBuilders.kt69 public fun <T> (() -> T).asFlow(): Flow<T> = flow { in <lambda>() method
84 public fun <T> (suspend () -> T).asFlow(): Flow<T> = flow { in <lambda>() method
91 public fun <T> Iterable<T>.asFlow(): Flow<T> = flow { in <lambda>() method
100 public fun <T> Iterator<T>.asFlow(): Flow<T> = flow { in <lambda>() method
109 public fun <T> Sequence<T>.asFlow(): Flow<T> = flow { in <lambda>() method
155 public fun <T> Array<T>.asFlow(): Flow<T> = flow { in <lambda>() method
166 public fun IntArray.asFlow(): Flow<Int> = flow { in <lambda>() method
177 public fun LongArray.asFlow(): Flow<Long> = flow { in <lambda>() method
186 public fun IntRange.asFlow(): Flow<Int> = flow { in <lambda>() method
195 public fun LongRange.asFlow(): Flow<Long> = flow { in <lambda>() method
DChannels.kt177 public fun <T> BroadcastChannel<T>.asFlow(): Flow<T> = flow { in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DMigration.kt36 public fun <T : Any> Publisher<T>.asFlow(batchSize: Int): Flow<T> = asFlow().buffer(batchSize) method
DReactiveFlow.kt29 public fun <T : Any> Publisher<T>.asFlow(): Flow<T> = in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/
DReactiveFlow.kt25 public fun <T : Any> JFlow.Publisher<T>.asFlow(): Flow<T> = in asFlow() method
/external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/
DJavaFxConvert.kt28 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.kt79 public fun <T: Any> ObservableSource<T>.asFlow(): Flow<T> = callbackFlow { in <lambda>() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxConvert.kt79 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
/external/kotlinc/lib/
Dkotlinx-coroutines-core.jarMETA-INF/ META-INF/MANIFEST.MF kotlinx/ kotlinx/coroutines/ kotlinx/ ...