hello I m trying to figure out the proper way to do interop

Question

hello I m trying to figure out the proper way to do interop between reactor and coroutines I need to populate reactor subscriber context with value computed from coroutine

Dariusz Kuc · Answer

i tried doing something like this <https github com dariuszkuc graphql kotlin blob spring server graphql kotlin spring server src main kotlin com expediagroup graphql spring execution ContextWebFilter kt L38>

Dariusz Kuc · Answer

but it fails unit test with step verifier gt <https github com dariuszkuc graphql kotlin blob spring server graphql kotlin spring server src test kotlin com expediagroup graphql spring execution ContextWebFilterTest kt L44>

gildor · Answer

Probably make sense to ask in < C0B8ZTWE4|spring> or check their implementation as I remember the last versions of Spring provide some integration with reactor context for coroutines

Dariusz Kuc · Answer

yeah already did and waiting for response

withoutclass · Answer

Latest spring supports coroutines and should not require special interop

Dariusz Kuc · Answer

also as a side note gt that webfilter logic does seem to work fine as when i start the spring boot app it properly populates it

gildor · Answer

Dariusz Kuc · Answer

might be just unit test

Dariusz Kuc · Answer

yeah it should work slightly smiling face

withoutclass · Answer

gildor · Answer

I m not familiar with reactor but curious what kind integration so you need what you want to achieve

Dariusz Kuc · Answer

well i m trying to have some unit test for verifying the context is populated right

Dariusz Kuc · Answer

so that step verifier tests worked fine when i used regular method to calculate value to be stored in the reactor subscriber context

Dariusz Kuc · Answer

but unfortunately it broke when i moved to coroutines

Dariusz Kuc · Answer

it does seem like an issue with reactor step verifier

Dariusz Kuc · Answer

to complete the thread gt so the issue was that step verifier attempts to verify the context on the result of the filter mono chain Since final value is not yet computed there is nothing yet added to the context so the StepVerifier checks against the context will fail Unit test fix was to manually capture the context in the reactor chain and then complete it before attempting to verify the context <https github com ExpediaGroup graphql kotlin pull 361 commits f746a886ddd97fa11dd29badecc8d7014d6fc75c>