Skip to content

examples: Reflow manualflowcontrol; check isReady() earlier #12726

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ejona86 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

examples: Reflow manualflowcontrol; check isReady() earlier #12726

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 7 additions & 1 deletion examples/src/main/java/io/grpc/examples/manualflowcontrol/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,13 @@ value.

### Outgoing Flow Control

The underlying layer (such as Netty) manages a buffer for outgoing messages. If you write messages faster than they can be sent over the network, this buffer will grow, which can eventually lead to an OutOfMemoryError. The outgoing onNext method invocation does not block when this happens. Therefore, you should explicitly check that the stream is ready for writing via `CallStreamObserver.isReady()` before calling onNext to avoid buffering excessive amounts of data in memory.
The underlying layer (such as Netty) manages a buffer for outgoing messages. If
you write messages faster than they can be sent over the network, this buffer
will grow, which can eventually lead to an OutOfMemoryError. The outgoing onNext
method invocation does not block when this happens. Therefore, you should
explicitly check that the stream is ready for writing via
`CallStreamObserver.isReady()` before generating messages to avoid buffering
excessive amounts of data in memory.

### Incoming Manual Flow Control

Expand Down
Loading