package polyglot.server;

import io.grpc.stub.StreamObserver;
import polyglot.HelloProto.HelloRequest;
import polyglot.HelloProto.HelloResponse;
import polyglot.HelloServiceGrpc.HelloService;

public class HelloServiceImpl implements HelloService {
  @Override
  public void sayHello(HelloRequest request, StreamObserver<HelloResponse> responseStream) {
    responseStream.onNext(HelloResponse.getDefaultInstance());
  }
}

@@ -410,14 +410,48 @@
 nce());%0A
+    responseStream.onCompleted();%0A
   %7D%0A%7D%0A

Make sure we always call onCompleted when responding to rpcs.