java - gRPC如何在流中的两条消息之间设置超时

Question

当我有一个流式 RPC（无论是客户端还是服务器端或双向流式传输）时，如果我想通过在两条消息之间设置超时来监视我的流是否仍然处于活动状态，我该如何实现呢？（首选Java，因为gRPC API在语言之间有很大不同）提前致谢！

编辑：添加了关于“两条消息之间的超时”的解释。

我想象的“两条消息之间的超时”是这样的。客户端从服务器接收消息流，客户端不知道该流何时结束（服务器完成该流）。例如，服务器将 S1、S2、S3、S4...S10 流回客户端。如果服务器在发送 S5 之前就卡住了，客户端在收到 S4 后就会“超时”。请注意，这不是整个流完成的超时，而是消息 Si 和 S(i+1) 之间的超时（流中每两条消息之间）。

标签： javagrpc