что ивенты будут происхоть в разные моменты и ну так например поток данных которые нужно будет разбить по пакетам и emit каждого пакета отдельно в процессе поступления .
Потому что ваша собственная реализация коллекта будет почти наверняка с проблемами. Там не так много нюансов при использовании, но очень много в реализации. То, что вы хотите делается путем комбинации канала и flow, делаете внутри класса приватный канал с нужной емкостью и пихаете новые события туда, а во вне может торчать fun flow() = channel.recieveAsFlow() или consumeAsFlow в зависимости от того, что вам нужно.
Обсуждают сегодня