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 0dd9a84 commit 33a0261Copy full SHA for 33a0261
src/main/java/io/reactivesocket/internal/Responder.java
@@ -716,10 +716,11 @@ public void request(long n) {
716
// after we are first subscribed to then send
717
// the initial frame
718
s.onNext(requestFrame);
719
- // initial requestN back to the requester (subtract 1
720
- // for the initial frame which was already sent)
721
- child.onNext(
722
- Frame.RequestN.from(streamId, rn.intValue() - 1));
+ if (rn.intValue() > 0) {
+ // initial requestN back to the requester (subtract 1
+ // for the initial frame which was already sent)
+ child.onNext(Frame.RequestN.from(streamId, rn.intValue() - 1));
723
+ }
724
}, r -> {
725
// requested
726
child.onNext(Frame.RequestN.from(streamId, r.intValue()));
0 commit comments