call requestChannelWith 2 arguments

robertroeser · robertroeser · commit f2a73a892368 · 2019-01-30T17:32:27.000-08:00
Signed-off-by: Robert Roeser &lt;rroeserr@gmail.com&gt;
diff --git a/rsocket-core/src/main/java/io/rsocket/RSocketServer.java b/rsocket-core/src/main/java/io/rsocket/RSocketServer.java
@@ -214,7 +214,7 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
   @Override
   public Flux<Payload> requestChannel(Payload payload, Publisher<Payload> payloads) {
     try {
-      return responderRSocket.requestChannel(payloads);
+      return responderRSocket.requestChannel(payload, payloads);
     } catch (Throwable t) {
       return Flux.error(t);
     }

Original file line number	Diff line number	Diff line change
`@@ -214,7 +214,7 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {`
`214`	`214`	`@Override`
`215`	`215`	`public Flux<Payload> requestChannel(Payload payload, Publisher<Payload> payloads) {`
`216`	`216`	`try {`
`217`		`- return responderRSocket.requestChannel(payloads);`
	`217`	`+ return responderRSocket.requestChannel(payload, payloads);`
`218`	`218`	`} catch (Throwable t) {`
`219`	`219`	`return Flux.error(t);`
`220`	`220`	`}`