File tree 1 file changed +2
-8
lines changed
reactive/kotlinx-coroutines-jdk9/src
1 file changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -17,20 +17,14 @@ import org.reactivestreams.FlowAdapters
17
17
* More precisely, it specifies the value of the subscription's [request][Subscription.request].
18
18
* `1` is used by default.
19
19
*
20
- * If any of the resulting
21
- flow transformations fails, subscription is immediately cancelled and all in-flights elements
22
- * are discarded.*
23
- * This function is integrated with `ReactorContext` from `kotlinx-coroutines-reactor` module,
24
- * see its documentation for additional details.
20
+ * If any of the resulting flow transformations fails, subscription is immediately cancelled and
21
+ * all in-flights elements are discarded.
25
22
*/
26
23
public fun <T : Any > Publisher<T>.asFlow (): Flow <T > =
27
24
FlowAdapters .toPublisher(this ).asFlow()
28
25
29
26
/* *
30
27
* Transforms the given flow to a reactive specification compliant [Publisher].
31
- *
32
- * This function is integrated with `ReactorContext` from `kotlinx-coroutines-reactor` module,
33
- * see its documentation for additional details.
34
28
*/
35
29
public fun <T : Any > Flow<T>.asPublisher (): Publisher <T > {
36
30
val reactivePublisher : org.reactivestreams.Publisher <T > = this .asPublisher<T >()
You can’t perform that action at this time.
0 commit comments