examples: add missing annotation

This commit is contained in:
raozihao 2019-10-30 15:26:19 +08:00 committed by Jihun Cho
parent d04529256a
commit c22e04223b
1 changed files with 1 additions and 0 deletions

View File

@ -55,6 +55,7 @@ public class ManualFlowControlServer {
// from being processed by the incoming StreamObserver. The onReadyHandler must return in a timely manor or else
// message processing throughput will suffer.
serverCallStreamObserver.setOnReadyHandler(new Runnable() {
@Override
public void run() {
if (serverCallStreamObserver.isReady() && wasReady.compareAndSet(false, true)) {
logger.info("READY");