Помогите, пожалуйста. У меня есть Flow<ByteArray>, который приходит из очень

Question

Помогите, пожалуйста. У меня есть Flow<ByteArray>, который приходит из очень

медленного источника. Мне надо его отправить по сети на удаленный сервис. Проблема в том, что сервис успевает отвалиться по таймауту ибо источник оооочень медленный. Я хочу сначала сбросить данные в локальный файл, а потом быстренько из файла отдать по сети. Хочу написать функцию `fun cache(data: Flow<ByteArray>): Flow<ByteArray>` которая бы сначала сложила исходный data в файл, а потом вернула новый флоу, читающий из этого файла. Как это правильно сделать? Объемы данных большие, в память не помещаются.

#kotlin #programming #russian

0

13.04.2021