Я ищу функцию в реактивном банане, которая будет выбирать, из какого потока событий выдавать следующий, в зависимости от входящего значения другого потока событий или сигнала (Поведение?). В библиотеке для scala, reactive-web это делается с помощью:
flatMap[U](f: T => EventStream[U]): EventStream[U]
Благодарность !