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 eaf137e commit 682fca3Copy full SHA for 682fca3
rsocket-core/src/main/java/io/rsocket/core/RequestOperator.java
@@ -93,7 +93,6 @@ public Context currentContext() {
93
94
@Override
95
public void request(long n) {
96
- this.s.request(n);
97
if (!firstRequest) {
98
try {
99
this.hookOnRemainingRequests(n);
@@ -115,6 +114,7 @@ public void request(long n) {
115
114
if (firstLoop) {
116
firstLoop = false;
117
+ this.s.request(Long.MAX_VALUE);
118
this.hookOnFirstRequest(n);
119
} catch (Throwable throwable) {
120
onError(throwable);
0 commit comments