File tree 2 files changed +0
-4
lines changed
kotlinx-coroutines-reactive/src
kotlinx-coroutines-reactor/src
2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -23,14 +23,12 @@ import kotlin.coroutines.*
23
23
* If any of the resulting flow transformations fails, subscription is immediately cancelled and all in-flights elements
24
24
* are discarded.
25
25
*/
26
- @ExperimentalCoroutinesApi
27
26
public fun <T : Any > Publisher<T>.asFlow (): Flow <T > =
28
27
PublisherAsFlow (this , 1 )
29
28
30
29
/* *
31
30
* Transforms the given flow to a spec-compliant [Publisher].
32
31
*/
33
- @ExperimentalCoroutinesApi
34
32
public fun <T : Any > Flow<T>.asPublisher (): Publisher <T > = FlowAsPublisher (this )
35
33
36
34
private class PublisherAsFlow <T : Any >(
Original file line number Diff line number Diff line change 4
4
5
5
package kotlinx.coroutines.reactor
6
6
7
- import kotlinx.coroutines.*
8
7
import kotlinx.coroutines.flow.Flow
9
8
import kotlinx.coroutines.flow.flowOn
10
9
import kotlinx.coroutines.reactive.FlowSubscription
@@ -15,7 +14,6 @@ import reactor.core.publisher.Flux
15
14
* Converts the given flow to a cold flux.
16
15
* The original flow is cancelled when the flux subscriber is disposed.
17
16
*/
18
- @ExperimentalCoroutinesApi
19
17
public fun <T : Any > Flow<T>.asFlux (): Flux <T > = FlowAsFlux (this )
20
18
21
19
private class FlowAsFlux <T : Any >(private val flow : Flow <T >) : Flux<T>() {
You can’t perform that action at this time.
0 commit comments