Evgeniy Zaharov
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"
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()
Reactor context in Flow: null Reactor context from defer: Context1{answer=42}
A modern programming language that makes developers happier.