Ок, хотя не уверен, что у меня что-то нетривиальное будет)
Ну в общем, мы будем рады написать конкретный пример и добавить фичи под use case (но вообще фич там уже много). После релиза kotlin 1.4.20 будет большой релиз со всеми новыми фичами
ребят, подскажите, возможно ли обработать такой случай, когда мне надо в одном методе запустить flow A, а вернуть из метода flow B, при этом из flow A надо сразу собирать/обрабатывать параллельно данные? а то походу я до строки с возвратом из метода даже не дохожу (flow A по сути подключается к сокетам и живет долго, соответственно)
ребят, подскажите, возможно ли обработать такой случай, когда мне надо в одном методе запустить flow A, а вернуть из метода flow B, при этом из flow A надо сразу собирать/обрабатывать параллельно данные? а то походу я до строки с возвратом из метода даже не дохожу (flow A по сути подключается к сокетам и живет долго, соответственно)
Все возможно, особенно если вы скажете, что значит сразу.
ну то бишь как-то так: fun somMethod() { source.funWithFlow().collect { // do something } return getAnotherFlow() }
Collect подвисает до исчерпания входного flow. Посмотрите реализацию map из kotlinx coroutines. Для параллельной обработки есть примеры в соответствующей issue
Collect подвисает до исчерпания входного flow. Посмотрите реализацию map из kotlinx coroutines. Для параллельной обработки есть примеры в соответствующей issue
С map тогда flow вообще не запускается или что-то такое, но данные я не получаю тогда. А о каком/каких issue речь, можно чуть подоробнее, это действительно могло бы помочь?
С map тогда flow вообще не запускается или что-то такое, но данные я не получаю тогда. А о каком/каких issue речь, можно чуть подоробнее, это действительно могло бы помочь?