Skip to content
This repository was archived by the owner on Feb 23, 2023. It is now read-only.
This repository was archived by the owner on Feb 23, 2023. It is now read-only.

Reactive return type support for RSocket #408

@linux-china

Description

@linux-china

Add the Reactive return type for RSocket like following:

   @MessageMapping("request-response")
    public Mono<String> requestResponse(String name) {
        return Mono.just("Hello "+name);
    }

Start the RSocket server, make a request, and exception stacktrace thrown like following:

org.springframework.messaging.MessagingException: No encoder for reactor.core.publisher.Mono<java.lang.String>, current value type is class reactor.core.publisher.MonoJust

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions