Skip to content

RSocketRequester.ResponseSpec Kotlin extensions issue #23185

@slawluc

Description

@slawluc

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.

  • 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

Metadata

Metadata

Assignees

Labels

in: messagingIssues in messaging modules (jms, messaging)type: bugA general bug

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions