Skip to content

Commit 4ec6edb

Browse files
yschimkeNiteshKant
authored andcommitted
Correct call to RemoteSender - streamId and initialRemoteRequested (#210)
Correct call to RemoteSender - streamId and initialRemoteRequested Seems like a typo Two constructors are ``` public RemoteSender(Publisher<Frame> originalSource, Runnable cleanup, int streamId, int initialRemoteRequested) { public RemoteSender(Publisher<Frame> originalSource, Runnable cleanup, int streamId) { ```
1 parent 0b80c06 commit 4ec6edb

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

reactivesocket-core/src/main/java/io/reactivesocket/ClientReactiveSocket.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ private Publisher<Payload> handleStreamResponse(Px<Payload> request, FrameType r
159159
int streamId = nextStreamId();
160160
RemoteSender sender = new RemoteSender(request.map(payload -> Frame.Request.from(streamId, requestType,
161161
payload, 1)),
162-
removeSenderLambda(streamId), 1);
162+
removeSenderLambda(streamId), streamId, 1);
163163
Publisher<Frame> src = s -> {
164164
CancellableSubscriber<Void> sendSub = doOnError(throwable -> {
165165
s.onError(throwable);

0 commit comments

Comments
 (0)