You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Really glad you're integrating Kotlin, Coroutines and RSocket into the messaging module @sdeleuze
I think inline reified generics are needed on these new methods.
data
retrieveFlow
retrieveFlux
retrieveAndAwait
retrieveMono
requester.route("myRoute").data("123").retrieveFlow<String>()
gives me the following error
Caused by: java.lang.IllegalArgumentException: No decoder for ? at o.s.m.r.RSocketStrategies.decoder(RSocketStrategies.java:85) at o.s.m.r.DefaultRSocketRequester$DefaultResponseSpec.retrieveFlux(DefaultRSocketRequester.java:366) at o.s.m.r.DefaultRSocketRequester$DefaultResponseSpec.retrieveFlux(DefaultRSocketRequester.java:339)
I have a patch to fix the code and test in gist.
I can submit as a pull request shortly
The text was updated successfully, but these errors were encountered:
Affects: Spring Framework 5.2.0-M3
Really glad you're integrating Kotlin, Coroutines and RSocket into the messaging module @sdeleuze
I think inline reified generics are needed on these new methods.
requester.route("myRoute").data("123").retrieveFlow<String>()
gives me the following error
Caused by: java.lang.IllegalArgumentException: No decoder for ? at o.s.m.r.RSocketStrategies.decoder(RSocketStrategies.java:85) at o.s.m.r.DefaultRSocketRequester$DefaultResponseSpec.retrieveFlux(DefaultRSocketRequester.java:366) at o.s.m.r.DefaultRSocketRequester$DefaultResponseSpec.retrieveFlux(DefaultRSocketRequester.java:339)
I have a patch to fix the code and test in gist.
I can submit as a pull request shortly
The text was updated successfully, but these errors were encountered: