Это общий вопрос реактивного программирования:
У меня есть наблюдаемая, которая получает координату (x, y) в качестве входных данных.Только подписчики, которые передают функцию hitTest (), должны быть уведомлены.Как я могу это сделать?
Все алгоритмы и т. Д., Доступные для потоков моделей, работают только с потоком данных (вход), но никогда не с подписчиками (выход).
Я ищудля чего-то вроде: observable.filterSubscribeers (...)
Или я здесь упускаю фундаментальную концепцию RX?