ЗП
Есть вопрос по FRP.Event, можно ли как-то flatMap с ним сделать? Типа:
f :: Event (List Int) -> Event Int
это же просто
mapmap sumSize: a a a
2019 January 03
ЗП
например
AK
например
map sumТут надо не
sum, к сожалению, а чтобы в результирующий ивент высылались все элементы списка по очередиЗП
тогда это просто какой-то
forЗП
for e \x -> do
...
ЗП
ну или
traverseAK
Event не Traversable и не Foldable
AK
Там есть
folded, но это кажется не тоЗП
AK
Есть входящий поток значений, его нужно обработать функцией, которая на каждое событие во входящем потоке вернёт массив/список значений, которые надо "выровнять" и "отправить" по одному в результирующий ивент.
AK
А, ну можно, в принципе, подписаться на первый и слать во второй их по очереди
AK
но это с эффектом, который надо будет отменить потом
AK
subscribe отдаёт CancelerAK
тут я не очень знаю, когда прервать второй ивент, поэтому хотелось бы без подписки, если это возможно
AK
но наверное это правда effectful-операция и нужен
traverse, потому что результирующий поток становится асинхронен с входящимAK
типа в первый пришло одно значение, а второй в ответ может выдать ещё пять
AK
понял проблему, буду думать
AK
тут я не очень знаю, когда прервать второй ивент, поэтому хотелось бы без подписки, если это возможно
нет, знаю, надо прервать подписку второго когда массив "кончился", тогда в принципе логика понятна.
AK
нет, знаю, надо прервать подписку второго когда массив "кончился", тогда в принципе логика понятна.
протупил, массив не "кончается", на каждой итерации первого потока это новый массив, короче нужен аналог
flatten или flatMap из всяких реактивных библиотек на JS. если можно определить, когда точно закончить подписку (исходный поток заканчивает юзер), то и такой вариант подойдёт.