Я настроил брокера паба / вложенного сообщения, используя gRPC, поэтому у меня есть:
- Publish(PublishRequest) returns (PublishReply) для публикации сообщений
- Subscribe(SubscribeRequest) returns (stream Message) поток на стороне сервера для приема сообщений.
Это на самом деле работает, но моя проблема в том, что канал подписки закрывается после того, как сервер отправит все сохраненные сообщения подписанному клиенту. Вместо этого я хотел бы, чтобы поток оставался открытым, поэтому, когда другой клиент публикует сообщение, подписанный «мгновенно получает уведомление».