Интересно, какой лучший подход для запуска события после завершения нескольких (неупорядоченных) вызовов ajax. Чтобы сделать это немного яснее, я хотел бы вызвать метод doSomethingGreat(), который запускает несколько вызовов ajax, порядок, в...

Как мне импортировать в GHCJS функцию Javascript, подобную следующей? xs.subscribe(function(x) { console.log(x) }) Я безуспешно пробовал различные комбинации следующих действий: data Observable_ data Disposable_ type Observable a = JSRef...

Ребята, у меня есть приложение, использующее RxJS для обработки событий мыши. Я складываю эти события в более сложные наблюдаемые «жесты». Один из таких жестов - «встряхнуть». Я пытаюсь составить следующие серии событий: mousedown mousemove...

Я пытаюсь ограничить, какие события, поступающие из общей шины сообщений, должны отправляться на сервер. Разрешенные события находятся в массиве outgoingEvents . Проблема в том, что для правильной отправки им сервера мне нужно имя события. var...

Отказ от ответственности: это продолжение предыдущего вопроса Безопасное обновление для 2 зависимых потоков Каков идиоматический способ обработки ошибок в RxJS (или любой другой реализации RX), который позволяет потоку не прерываться?...

У меня есть особая проблема производителя-потребителя в RxJS: производитель медленно производит элементы. Потребитель запрашивает элементы и часто должен ждать производителя. Этого можно добиться, заархивировав производителя и поток запросов:...

Каков самый простой способ выполнить побочный эффект при удалении последней подписки для RxJS Observable? Это может произойти до завершения работы Observable . Допустим, мне нужна функция, возвращающая Observable , которая передает изменения в...

Я использую AngularJS 2 Beta 0 и пытаюсь создать наблюдаемый RxJS из события в оконном объекте. Я считаю, что знаю формулу захвата события как наблюдаемого в моем сервисе: var observ = Observable.fromEvent(this.windowHandle, 'hashchange');...

У меня есть два потока темы поведения, которые я безуспешно пытаюсь разветвить. Как я и предполагал, он возвращает два последних значения. Возможно ли это как-то реализовать? Он не называется после подлежащего. let stream1 = new...