Why RepositoryMethodInvoker.doInvokeReactiveToSuspended strips coroutine continuation?

[ojh3636]

[Version: spring-data-commons-2.4.13]

Hi, I have quesiton during digging the behavior of r2dbc, CoroutineCrudRepository.

First of all, What I want to do is logging query with some metadata that only can be retrieved from outer reactor or coroutine context (ex> ipath, eventId, spanId ..).

What I try first is

1. Register ProxyConnectionFactory and register listener to log query.
2. I wrote the code inside proxy listener that obtain "currentCoroutineContext[ReactorContext]" and use them when logging

But I found that "currentCoroutineContext[ReactorContext]" returns empty.

And I digging the repository behavior and I encounter below code.

Does the code in L168 means that all methods that are invoked in repository interface loose outer ractor or coroutine context?

Is there any way that can pass the outer coroutine or reactor context into repository method invokation?

Thank you.

[mp911de]

I moved the ticket to Spring Data Commons as the code lives there.

[mp911de]

doInvokeReactiveToSuspended adapts a coroutine call to a reactive one by calling the backing reactive method that returns a Publisher. The expectation is that AwaitKt.awaitSingleOrNull(…) accepting the Continuation parameter subscribes correctly to the publisher and propagates the context correctly. If the context gets lost, then this is a bug. Maybe @sdeleuze can provide more insights how we can address the context loss.

[ojh3636]

Thank you for answer. To be clear the AwaitKt.awaitSingleOrNull(result, continuation) properly propagate context after reactive repository works(like select, update,..). But what I want to do is, want to capture the context "inside" the reactive repository works. Now, the context propagated as below

Some Code with Context -> repository method invoke without context -> after code with context

But I want to get parent context in repository method.

[mp911de]

Can you provide an example (minimal reproducer) of what you're trying to achieve? The textual description doesn't really make that clear. With a reproducer, we can actually check what's required to make it work.

[ojh3636]

Ok I'ill make some reproducable example project! Thank you