diff options
Diffstat (limited to 'reactive/kotlinx-coroutines-reactor/src/Flux.kt')
| -rw-r--r-- | reactive/kotlinx-coroutines-reactor/src/Flux.kt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/reactive/kotlinx-coroutines-reactor/src/Flux.kt b/reactive/kotlinx-coroutines-reactor/src/Flux.kt index 316146b5..18b84ac1 100644 --- a/reactive/kotlinx-coroutines-reactor/src/Flux.kt +++ b/reactive/kotlinx-coroutines-reactor/src/Flux.kt @@ -74,4 +74,4 @@ private fun <T> reactorPublish( val coroutine = PublisherCoroutine(newContext, subscriber) subscriber.onSubscribe(coroutine) // do it first (before starting coroutine), to avoid unnecessary suspensions coroutine.start(CoroutineStart.DEFAULT, coroutine, block) -} +}
\ No newline at end of file |