File tree Expand file tree Collapse file tree 2 files changed +0
-4
lines changed
kotlinx-coroutines-reactive/src
kotlinx-coroutines-reactor/src Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -23,14 +23,12 @@ import kotlin.coroutines.*
2323 * If any of the resulting flow transformations fails, subscription is immediately cancelled and all in-flights elements
2424 * are discarded.
2525 */
26- @ExperimentalCoroutinesApi
2726public fun <T : Any > Publisher<T>.asFlow (): Flow <T > =
2827 PublisherAsFlow (this , 1 )
2928
3029/* *
3130 * Transforms the given flow to a spec-compliant [Publisher].
3231 */
33- @ExperimentalCoroutinesApi
3432public fun <T : Any > Flow<T>.asPublisher (): Publisher <T > = FlowAsPublisher (this )
3533
3634private class PublisherAsFlow <T : Any >(
Original file line number Diff line number Diff line change 44
55package kotlinx.coroutines.reactor
66
7- import kotlinx.coroutines.*
87import kotlinx.coroutines.flow.Flow
98import kotlinx.coroutines.flow.flowOn
109import kotlinx.coroutines.reactive.FlowSubscription
@@ -15,7 +14,6 @@ import reactor.core.publisher.Flux
1514 * Converts the given flow to a cold flux.
1615 * The original flow is cancelled when the flux subscriber is disposed.
1716 */
18- @ExperimentalCoroutinesApi
1917public fun <T : Any > Flow<T>.asFlux (): Flux <T > = FlowAsFlux (this )
2018
2119private class FlowAsFlux <T : Any >(private val flow : Flow <T >) : Flux<T>() {
You can’t perform that action at this time.
0 commit comments