From ad2cc6f945672c25c4bd8723384d58bbad892797 Mon Sep 17 00:00:00 2001 From: Ran Date: Wed, 27 Mar 2024 13:34:53 -0700 Subject: [PATCH] Make setOnReadyThreshold() noop by default. --- .../main/java/io/grpc/stub/ServerCallStreamObserver.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java b/stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java index 614cc2bf24a..dcbe86458a3 100644 --- a/stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java +++ b/stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java @@ -16,6 +16,8 @@ package io.grpc.stub; +import static com.google.common.base.Preconditions.checkArgument; + import io.grpc.ExperimentalApi; /** @@ -140,7 +142,9 @@ public void disableAutoRequest() { * @param onReadyHandler to call when peer is ready to receive more messages. */ @Override - public abstract void setOnReadyHandler(Runnable onReadyHandler); + public void setOnReadyHandler(Runnable onReadyHandler) { + checkArgument(numBytes > 0, "numBytes must be positive: %s", numBytes); + } /** * Requests the peer to produce {@code count} more messages to be delivered to the 'inbound'