Flow и каналы

Холодный Flow не делает ничего, пока его не собирают, и перезапускает производителя отдельно для каждого коллектора, поэтому каждый получает свою личную последовательность. SharedFlow горячий: он испускает значения независимо от наличия слушателей, и все его коллекторы делят один поток эмиссий от одного производителя.

Никогда в момент объявления. Промежуточный оператор вроде map, filter или onEach лишь возвращает новый Flow, оборачивающий предыдущий, так что построение цепочки не делает никакой работы. Вся цепочка выполняется, когда её запускает терминальный оператор — collect, first, toList, — по разу на каждый сбор.

suspend-функция выполняется один раз и возвращает одно значение. Flow испускает много значений во времени, и коллектор обрабатывает каждое по мере поступления. Flow холодный: блок-производитель запускается лишь при вызове терминального оператора вроде collect и начинается заново для каждого коллектора.

Channel — это горячая очередь с приостановкой: send приостанавливается, пока буфер полон, а receive — пока он пуст. Каждый элемент достаётся ровно ОДНОМУ получателю: два получателя разбирают работу между собой, а не получают по копии. Именно это делает его инструментом передачи producer/consumer.

flowOn меняет контекст только для операторов ВЫШЕ по цепочке — для производителя и всего, что объявлено до вызова. Коллектор всегда работает в контексте той корутины, которая вызвала collect, потому что Flow сохраняет контекст. Поэтому parseHeavy внутри collect остаётся на главном потоке; перенесите его выше flowOn.

StateFlow всегда хранит ровно одно текущее значение, склеивает быстрые эмиссии и отбрасывает значение, равное предыдущему, — поэтому он моделирует состояние, и новый коллектор сразу получает последнее значение. SharedFlow не хранит значения и настраивается (replay, буфер, overflow), поэтому он и есть инструмент для одноразовых событий.

По умолчанию сбор последовательный: медленный коллектор создаёт обратное давление, и emit приостанавливается. buffer разводит производителя и коллектор по отдельным корутинам с очередью между ними. conflate оставляет лишь самое свежее значение, отбрасывая промежуточные. collectLatest отменяет тело коллектора на каждом новом значении и перезапускает его.

StateFlow склеивает эмиссии и ведёт себя так, будто на нём стоит distinctUntilChanged, поэтому присваивание значения, равного текущему, не испускает ничего — второй одинаковый Toast отбрасывается до коллектора. StateFlow моделирует состояние, а не события: публикуйте их через MutableSharedFlow и emit.

Отдавайте Flow, когда каждый коллектор должен видеть весь поток, а производитель — стартовать по требованию: он холодный и перезапускается на коллектора, так что ничего не течёт, если его никто не собирает. Channel берите только для горячей передачи, где элемент обязан достаться ровно одному потребителю.

Сделайте базу единственным источником истины: возвращайте её query-Flow, тогда любая запись переиспускает список и UI не отстаёт от хранилища. Обновление запускайте из самого потока, а сетевой результат пишите В базу, а не испускайте. Ошибки отдавайте отдельным потоком, чтобы неудачное обновление оставило кэш нетронутым. Разделяйте поток через stateIn(WhileSubscribed).

catch работает только вверх по цепочке: он видит исключения производителя и операторов, объявленных ДО него, и больше ничего. Исключение внутри collect находится ниже, поэтому catch его не увидит и оно улетит вызывающему — это и есть exception transparency. Для временных сбоев выше берите retry/retryWhen, а для ошибок коллектора — обычный try/catch.