社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
当使用流式调用时,客户端需要生成非阻塞Stub:
StudentServiceGrpc.StudentServiceStub stub = StudentServiceGrpc.newStub(managedChannel);
然后围绕StreamObServer实现其onNext、onError和onCompleted方法即可。
注意,当客户端使用流式调用时,onNext是异步非阻塞的,不可以马上退出程序,需要等待一段时间才有返回。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!