Make setOnReadyThreshold() noop by default.

ran-su · Mar 27, 2024 · ad2cc6f · ad2cc6f
1 parent 2c5f0c2
commit ad2cc6f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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'