reactive-programming

1зной

1ответ

Higland.js: обернуть toCallback в обещание

Я хочу написать что-то вроде: const Promise = require('bluebird') const H = require('highland') Promise.fromCallback( H([1, 2, 3]).toCallback ).then(function(val) { expect(val).eql(1, 2,

javascript reactive-programming bluebird highland.js 2017-01-13

---

4зной

1ответ

Используя Observables, покажите индикатор загрузки после задержки, но отмените, если загрузка завершена вовремя?

В моем компоненте детали клиента у меня есть следующий код, который достигает того, что мне нужно, но не в реактивном/наблюдаемом способе, я думаю, это возможно. Вместо того, чтобы обертывать this.isL

angular typescript rxjs reactive-programming rxjs5 2017-01-16

---

0зной

1ответ

RxJS асинхронной обработка потоков

//app.js import $ from 'jquery'; import Rx from 'rxjs/Rx'; var $pull = $('#fetch');//this is a button id var pull$ =Rx.Observable.fromEvent($pull,'click').startWith("/hcdata.json"); var $result

javascript asynchronous rxjs reactive-programming 2017-01-16

---

0зной

1ответ

Горячие клавиши для запуска реактивных потоков в R Shiny?

Можно ли, скажем, F7 или Q активировать реактивный поток в блестящем приложении (в Windows)? This question предоставляет код для чередующихся вкладок с клавиатурным вводом, но меня интересует запуск р

javascript r shiny reactive-programming 2017-01-16

---

0зной

1ответ

Объединение groupBy и flatMap (maxConcurrent, ...) в RxJava/RxScala

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

scala rx-java reactive-programming rx-scala 2017-01-17

---

6зной

2ответ

Rx distinctUntilChanged позволяет повторение через настраиваемое время между событиями

Давайте на минуту следующего кода Rx.Observable.merge( Rx.Observable.just(1), Rx.Observable.just(1).delay(1000) ).distinctUntilChanged() .subscribe(x => console.log(x)) Мы ожидаем, чт

javascript rxjs reactive-programming rxjs5 2017-01-17

---

2зной

2ответ

Обновление версии io.projectreactor от 2.0.x до 3.0.4 - Использование Spring framework

У меня проблема при попытке выполнить обновление. В настоящее время я использую версию 2.0.x, и в частности - reactor.bus reactor.rx.Stream reactor.rx.Streams reactor.core.processor.RingBufferProce

java spring rx-java reactive-programming project-reactor 2017-01-17

---

2зной

1ответ

Должен ли я «думать» обо всех моих данных как потоках при работе с Observables?

Say мы получаем массив категории как JSON: [ {id: "111", name: "cat1"}, {id: "222", name: "cat2"}, {id: "333", name: "cat3"} ] метод получает его: getCategories(): Observable<Array<Category>> {

angular reactive-programming observable 2017-01-18

---

0зной

2ответ

В RxJava, что является тип снижения экспрессии

Рассмотрим следующее: import io.reactivex.Observable; import io.reactivex.observables.GroupedObservable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; public c

rx-java reactive-programming 2017-01-18

---

-1зной

1ответ

RxJS сложный zip два наблюдаемых

getLastOrder() и getUserDetails(lastOrder.owner) асинхронные операции. (оба значения возвращаются Observable) Ищите причудливого оператора, чтобы получить комбинированный результат, который будет вклю

rxjs reactive-programming 2017-01-18

---