We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9268bf6 commit 1eafd63Copy full SHA for 1eafd63
rsocket-rpc-core/src/main/java/io/rsocket/rpc/rsocket/RequestHandlingRSocket.java
@@ -25,11 +25,21 @@ public RequestHandlingRSocket(RSocketRpcService... services) {
25
}
26
27
28
+ /**
29
+ * @deprecated in favour of {@link #withService(RSocketRpcService)}
30
+ * @param rsocketService
31
+ */
32
+ @Deprecated
33
public void addService(RSocketRpcService rsocketService) {
34
String service = rsocketService.getService();
35
registeredServices.put(service, rsocketService);
36
37
38
+ public RequestHandlingRSocket withService(RSocketRpcService rSocketRpcService) {
39
+ addService(rSocketRpcService);
40
+ return this;
41
+ }
42
+
43
@Override
44
public Mono<Void> fireAndForget(Payload payload) {
45
try {
0 commit comments