2014-11-04 5 views
1

Я участвую в процессе обучения реактивному программированию в scala.Rx Scala сочетает в себе последние из нескольких потоков

Я нахожусь в месте, где мне нужно объединить набор потоков в один. Короче говоря, я объединять входы из редактора стиля GUI (подборщики цветов и т. Д.) В один полностью включенный поток. Для этого я мог бы использовать функцию combLatest наблюдаемых.

Rx Java Наблюдаемый предлагает варианты combLatest с как можно большим количеством входов. Rx Scala предлагает только для двух, а для остальных есть только бесполезен «Если C# не нужно, Scala не нуждается ни ;-)»

Итак, мой вопрос, что это просто способ получения кортежей значений из набора наблюдаемых каждый раз, когда наблюдаемые изменения?

ответ

2

В объекте Observable есть статическая функция. Не существует селектора по умолчанию, который создает кортеж. Нужно написать собственный селектор для объединения испускаемых значений