Я решил эту проблему сегодня.Когда пользователь подписывается на поток, сохраните запрос на подписку и наблюдателя потока в списке массивов / обычном списке.Позже, когда вызывается какая-либо служба действий.Создайте новый экземпляр службы Stream (которая расширяет ServerStreamServiceGrpc.ServerStreamServiceImplBase) и вызовите нужную потоковую службу из этого нового экземпляра с параметрами из списка массивов.Вам не нужно использовать тот же экземпляр службы, который использовался для создания сервера.Когда пользователь отписывается от потока, просто удалите эту подписку также из списка массивов.Убедитесь, что onCompleted () не вызывается всякий раз, когда вы отправляете какие-либо данные из службы потоковой передачи, поскольку это приведет к прекращению подписки.Здесь потоковая передача относится к потоковой передаче на стороне сервера.