requestStream should continue serving messages infinitely.
Actual Behavior
After Integer.MAX_VALUE messages, no more requestN frames are sent by the client, and the server stops sending messages.
The main problem is in io.rsocket.core.StateUtils. The sum of all requestN is limited by Integer.MAX_VALUE. The best solution will be to remove the limitation on the sum of requestN completely.
Expected Behavior
requestStreamshould continue serving messages infinitely.Actual Behavior
After
Integer.MAX_VALUEmessages, no morerequestNframes are sent by the client, and the server stops sending messages.The main problem is in
io.rsocket.core.StateUtils. The sum of allrequestNis limited byInteger.MAX_VALUE. The best solution will be to remove the limitation on the sum ofrequestNcompletely.