Не collector, а collect. Тот самый единственный (на данный момент) метод Flow.

Вот можно посмотреть реализацию: https://github.com/Kotlin/kotlinx.coroutines/blob/d55d8e80e152e46c170edc4dcfa08ccb7b2c4a03/kotlinx-coroutines-core/common/src/flow/Builders.kt#L334

Channel проблемы делает при большой нагрузке скипает данные хотя вроде и капасити  у него норм и работает под корутинами  и вроде как норм работает в других местах кода

Так самодельная штука у вас будет работать заведомо хуже. Проблема в том, что у вас не холодный Flow, а горячий. У вас есть скорость засовывания и скорость изымания. Скиать ничего он не может, вопрос в скорости потребления

Если у вас в ваших событиях нет back-pressure и вы не успеваете переработать все события, то вы в любом случае будете что-то пропускать. Это нельзя победить никаким способом

Мои извинения оказывается я уже давно заюзал в том месте channel и работает он там на ура без пропусков и проблем .

👍

Такой вопрос пример есть устройство ввода отсылает пакеты данных в виде стрима который нужно прочитать и разбить на пакеты данных в соответствии с протоколом , тоисть на в ходе есть инпут стрим  а на выходе пакеты причем стрим не всегда за раз присылает полный пакет так как он ограничен по скорости  на данный момент при сборке он в callback присылает готовый пакет данных по мере поступления данных и возможности собрать полный пакет из стрима ,  все работает и работает хорошо но хотелось бы переехать на то что более легче в юнит тестах , вопрос как бы вы реализовали эту ситуацию или бы оставили все как есть заранее спасибо

Вот прямо в сей момент это пишу. Для управления оборудованием. Я использую рабочую версию kotlinx-io, там есть готовая функция для строк readUtf8StringUntilDelimiters. Но проблема с тем, что io не дружит с корутинами, так что в любом случае там будут блокировки. Я хочу запустить сборку пакетов с блокировкой на io, а потом преобразовать во Flow. Но еще надо поэкспериментировать. Старая версия работала на колбэке - тоже с блокирующим сбором.

Могу дать ссылку на старый код трехлетней давности, но я его сейчас полностью переписываю

А что за устройства кстати?

BLE \ BT\ USB подключенный к кастомной плате со внутренним сенсорами
И собственной логикой и энкодингом данных

О, можем скооперироваться. Мы сейчас делаем мультиплатформную либу (открытую) как раз для общения с железками.

https://github.com/mipt-npm/dataforge-control. Основное наше применение - это всякие большие эксперименты в физике частиц, но я бы хотел, чтобы оно и для индустрии полезно было

В build.gradle как то можно использовать glob в таске Copy?
У меня есть такая таска:
task cpArtifacts(type: Copy) {
 from shadowJar
 into "$distRoot/*/dist"
}
shadowJar.finalizedBy cpArtifacts

И надо чтобы артефакты скопировались в директории, которые заматчит этот глоб

В компании в которой работаю примерно такая же сфера но предназначена для образования
http://einsteinworld.com/

Щас нету возможности так как и платформа закрытая и код нельзя в опен сорсе постить да и  за один он по большей части для внутренних нужд , хотя в будущем планирую
Переписать его под гражданские цели для удобства работы с железками

А я не предлагаю ваш код открывать, я предлагаю включиться в обсуждение по тому открытому проекту, что мы делаем, чтобы потом вы могли его использовать.

По обсуждать я всегда рад по мере возможности

Добрый день!

Столкнулся с одной проблемой и нуждаюсь в помощи. Опишу задачу:
Я в одни reqest-e получаю объект содержащий 4 переменных типа String(email,username,displayname,data) мне нужно взять лишь email из данного объекта для использования второго reqest-a так как для него нужен Auth and email.

Как я могу это сделать?