change.

Author: kannanjgithub

api/src/main/java/io/grpc/ServerCall.java

@@ -146,7 +146,7 @@ public void onReady() {}
    *
    * <p>If {@code false}, {@link Listener#onReady()} will be called after {@code isReady()}
    * transitions to {@code true}.
-   *
+   *[
    * <p>This abstract class's implementation always returns {@code true}. Implementations generally
    * override the method.
    */

examples/build.gradle

@@ -45,7 +45,7 @@ dependencies {
 protobuf {
     protoc { artifact = "com.google.protobuf:protoc:${protocVersion}" }
     plugins {
-        grpc { artifact = "io.grpc:protoc-gen-grpc-java:${grpcVersion}" }
+        grpc { artifact = "io.grpc:protoc-gen-grpc-java:1.70.0" }
     }
     generateProtoTasks {
         all()*.plugins { grpc {} }

examples/src/main/java/io/grpc/examples/helloworld/HelloWorldServer.java

@@ -83,6 +83,7 @@ static class GreeterImpl extends GreeterGrpc.GreeterImplBase {
 
     @Override
     public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
+      //throw new RuntimeException("fk");
       HelloReply reply = HelloReply.newBuilder().setMessage("Hello " + req.getName()).build();
       responseObserver.onNext(reply);
       responseObserver.onCompleted();

examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlServer.java

@@ -26,13 +26,29 @@
 import java.util.concurrent.TimeUnit;
 import java.util.logging.Logger;
 
+class MyWorker implements Runnable {
+  StreamObserver<HelloReply> responseObserver;
+  volatile boolean throwed = false;
+  @Override
+  public void run() {
+    while (true) {
+      if (throwed) {
+        responseObserver.onNext(HelloReply.newBuilder().setMessage("nai").build());
+        throwed = false;
+      }
+    }
+  }
+}
 public class ManualFlowControlServer {
   private static final Logger logger =
       Logger.getLogger(ManualFlowControlServer.class.getName());
 
   public static void main(String[] args) throws InterruptedException, IOException {
+    MyWorker myWorker = new MyWorker();
+    new Thread(myWorker).start();
     // Service class implementation
     StreamingGreeterGrpc.StreamingGreeterImplBase svc = new StreamingGreeterGrpc.StreamingGreeterImplBase() {
+
       @Override
       public StreamObserver<HelloRequest> sayHelloStreaming(final StreamObserver<HelloReply> responseObserver) {
         // Set up manual flow control for the request stream. It feels backwards to configure the request
@@ -70,11 +86,18 @@ public void run() {
         final OnReadyHandler onReadyHandler = new OnReadyHandler();
         serverCallStreamObserver.setOnReadyHandler(onReadyHandler);
 
+        myWorker.responseObserver = responseObserver;
+
         // Give gRPC a StreamObserver that can observe and process incoming requests.
         return new StreamObserver<HelloRequest>() {
           int cnt = 0;
           @Override
           public void onNext(HelloRequest request) {
+            int i = 9;
+            if (i > 0) {
+              myWorker.throwed = true;
+              throw new RuntimeException();
+            }
             // Process the request and send a response or an error.
             try {
               // Accept and enqueue the request.