reactive-programming

1зной

1ответ

Прочитайте файл асинхронно с RxJava 2

Я пытаюсь создать Observable<ByteBuffer> или Flowable<ByteBuffer>, который будет читать файл асинхронно (или, по крайней мере, я ищу лучшую производительность Java может дать мне в этом случае использ

java asynchronous rx-java reactive-programming rx-java2 2017-02-09

---

1зной

2ответ

Порядок установки Планировщики в Rx

Я действительно новым для Rx, просто интересно, как же порядок subscribeOn воздействия Observable //This will not print anything Observable.just("whatever") .flatMap { s -> Observable.just(s.le

rx-java kotlin reactive-programming 2017-02-10

---

1зной

1ответ

RXJS Subject, возвращайте то же самое значение при каждом первом подписании

Я знаю, что мне нужно использовать startWith, но все еще пытаюсь понять, как его использовать. Если я просто делаю Subject.create().startWith("Some Value), он превращает Subject в Observable, и я не м

javascript rxjs reactive-programming 2017-02-10

---

1зной

2ответ

Обработка подписки на RxJava на Android элегантно?

Есть ли элегантный способ обработки подписки на RxJava при работе с изменениями состояния Android (например, изменение ориентации) или событиями асинхронной платформы (например, события push-уведомлен

java android rx-java reactive-programming reactivex 2017-02-12

---

0зной

1ответ

Как фильтровать наблюдаемые данные с другими наблюдаемыми объектами

Проблема, с которой я столкнулся, выглядит следующим образом: У меня есть два наблюдаемых, которые извлекают данные из сети, а другие из db. Второй может быть пустым, но отсутствие первого считается о

java reactive-programming observable 2017-02-12

---

0зной

1ответ

Ионный 2: как получить ошибку из созданного Observable?

я определил следующие функции: searchProducts(searchText: string){ return Observable.create(observer => { return this._http.get(this._global.baseUrl + "/products/search/searchProducts?sear

angular ionic2 observablecollection reactive-programming reactive 2017-02-13

---