File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
rsocket/src/main/java/org/springframework/security/rsocket/core Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -91,10 +91,10 @@ public Flux<Payload> requestStream(Payload payload) {
9191 public Flux <Payload > requestChannel (Publisher <Payload > payloads ) {
9292 return Flux .from (payloads ).switchOnFirst ((signal , innerFlux ) -> {
9393 Payload firstPayload = signal .get ();
94- return intercept (PayloadExchangeType .REQUEST_CHANNEL , firstPayload ).flatMapMany (( context ) -> innerFlux
95- .index ().concatMap ((tuple ) -> justOrIntercept (tuple .getT1 (), tuple .getT2 ()))
96- .transform ((securedPayloads ) -> this .source .requestChannel (securedPayloads ))
97- .subscriberContext (context ));
94+ return intercept (PayloadExchangeType .REQUEST_CHANNEL , firstPayload ).flatMapMany (
95+ ( context ) -> innerFlux .index ().concatMap ((tuple ) -> justOrIntercept (tuple .getT1 (), tuple .getT2 ()))
96+ .transform ((securedPayloads ) -> this .source .requestChannel (securedPayloads ))
97+ .subscriberContext (context ));
9898 });
9999 }
100100
You can’t perform that action at this time.
0 commit comments