reactive-programming

0зной

1ответ

Я должен что-то супер очевидное здесь отсутствует ... public suggestedData$: Observable<string[]>; public suggestionStream = new Subject<string>(); nextSuggestion(){ this.suggestionStream.next

2зной

1ответ

Как написать свою собственную операцию над наблюдаемым, чтобы отобразить все на константу?

Я написал свой пользовательский наблюдаемый, который испускает объекты LatLng, когда пользователь перемещает карту Google. Также у меня есть BehaviorSubject<Boolean> locationTracking = BehaviorSubject

0зной

1ответ

Как правильно вывести общий шаблон в пользовательском операторе rxcpp

Я создал собственный оператор rxcpp с именем validateImplementation, который должен просто взять общий наблюдаемый поток, сделать некоторые проверки на SimpleInterface и продолжить или завершить поток

2зной

1ответ

RxJava выполняет операцию над списком и возвращает наблюдаемый

Я новичок в RxJava (в частности, RxJava2), и у меня возникают некоторые проблемы с тем, что кажется относительно простой операцией. Мне нужно получить некоторые данные из db, выполнить итерацию данных

0зной

1ответ

Возможно ли каким-либо образом удерживать выбросы Observable/Flowable и каким-то образом инициировать выбросы по мере необходимости?

Я новый пользователь RxJava2, и я использовал другие методы defer, concat и create. Я пытаюсь найти способ реализовать то, что я описал выше. Особая потребность в этом, у меня есть фрагмент, который п

0зной

2ответ

Rxjs - Невозможно преобразовать холодный наблюдаемый в горячий

Итак, я использую Angular 2 и изо всех сил пытаюсь сделать наблюдаемый HTTP-запрос доступным для нескольких наблюдателей. В частности, я хотел бы поделиться всеми типами ответов, включая ошибки. Я про