Я использую com.squareup.wire.GrpcStreamingCall вместе с OkHttp в мобильном приложении Kotlin для потоковой передачи событий gRPC из серверной службы. Проблема, с которой я столкнулся, заключается в том, что клиент не получает потоковые пакеты в режиме реального времени.
Вместо этого все пакеты буферизуются внутри и доставляются вместе только тогда, когда сервер закрывает соединение или истекает время сеанса (например, через 5 минут). Это противоречит смыслу потокового соединения.
С серверной стороны проблем нет, API в Postman работают нормально.
Ожидаемое поведение
Пакеты должны доставляться клиенту немедленно по мере их отправки сервером (в режиме реального времени).
Поток GrpcStreamingCall.response должен генерировать каждое сообщение по мере его поступления в сеть.
/>Фактическое поведение
Пакеты выдаются из потока только через несколько минут — когда сеанс закрывается или истекает время ожидания.
Все буферизованные пакеты поступают одновременно, как если бы они были задержаны или кэшированы.
Подробнее здесь: https://stackoverflow.com/questions/798 ... out-not-re
