Hi, I have a problem with switching from ReactorCo...

# coroutines

[Evgeniy Zaharov]

Hi, I have a problem with switching from ReactorContext to CoroutineContext
In coroutine-reactor docs I found an example:

val flow = flow<Unit> {
   println("Reactor context in Flow: " + coroutineContext[ReactorContext])
}

flow.asFlux()
    .subscriberContext { ctx -> ctx.put("answer", 42) }
    .subscribe() // Must print "Reactor context in Flow: Context{'answer'=42}" but print "Reactor context in Flow: null"

But with coroutine 1.4.0, 1.4.1 it prints Null. Am I miss something?

[Evgeniy Zaharov]

found a workaround

val flow = flow<Unit> {
            println("Reactor context in Flow: " + coroutineContext[ReactorContext])
            val context = Mono.deferWithContext { ctx -> Mono.just(ctx) }.awaitFirst()
            println("Reactor context from defer: $context")
        }
        flow.asFlux()
            .subscriberContext { ctx -> ctx.put("answer", 42) }
            .subscribe()

it will prints:

Reactor context in Flow: null
Reactor context from defer: Context1{answer=42}