reactive-programming

71Ciepło

2Odpowiedz

RxJS: Jak mogę "ręcznie" zaktualizować obserwowalne?

Myślę, że muszę się nieporozumienie coś fundamentalnego, ponieważ w moim umyśle powinien to być najbardziej podstawowy przypadek dla obserwowalne, ale dla mojego życia nie mogę dowiedzieć się, jak to

10Ciepło

1Odpowiedz

RxJava - Czy pamięć podręczna() jest taka sama jak funkcja odtwarzania()?

Zastanawiam się, czy istnieje operator cache(), który może buforować x liczbę emisji, ale także wygasać po określonym czasie (np. 1 minuta). Szukałem czegoś podobnego ... Observable<ImmutableList<MyTy

7Ciepło

1Odpowiedz

Czy anulowanie subskrypcji jest bezpieczne w aplikacji RxJava?

Załóżmy, że mam następujący kod RxJava (który uzyskuje dostęp do DB, ale dokładny przypadek użycia nie ma znaczenia): public Observable<List<DbPlaceDto>> getPlaceByStringId(final List<String> stringId

6Ciepło

1Odpowiedz

Jak mogę przejąć kontrolę nad canEditRowAtIndexPath, gdy używam rozszerzenia RxCocoa dla UITableView

Tylko dla zapisu przed uruchomieniem mojego pytania używam wersji beta Swift 2 i xcode 7. Używam RxSwift i RxCocoa do wiązania mojego ViewModel z TableView. W moim UITableViewController viewDidLoad ro

16Ciepło

5Odpowiedz

Jak utworzyć buforowanie/gorącą wersję rx.Single?

RxJava v1.0.13 wprowadziła nowy typ obserwowalnego: rx.Single. Pasuje on świetnie do modelu żądanie-odpowiedź, ale brakuje standardowych efektów ubocznych wprowadzających operatorów takich jak doOnNex

5Ciepło

1Odpowiedz

Reactive Banana: jak używać wartości ze zdalnego interfejsu API i scalać je w strumieniu zdarzeń

Używam Reactive-Banana w interfejsie WX. Po naciśnięciu przycisku muszę pobrać wartość z zewnętrznego interfejsu API usługi. Mam rodzajowy Behavior w oparciu o typ danych AppState, który "akumuluje" t

9Ciepło

2Odpowiedz

Bieg histogram strumień z Rx

Mam następujący pojedynczy strumień list A B C A D B A C D I z tego strumienia, chciałbym strumień uruchomiony Ilość na literę (A,1) (A,1), (B,1) (A,1), (B,1), (C,1) (A,2), (B,1), (C,1)

5Ciepło

2Odpowiedz

Jak uruchomić to oświadczenie za pomocą RxJava?

Rx sposób robienia rzeczy może być bardzo skomplikowana i żaden z wielu powodów ... ale czuję, istnieją proste sposoby wykonywania prostych rzeczy z RX ... Jak bym po prostu wykonać to oświadczenie w

7Ciepło

1Odpowiedz

RxJS: Dzielenie wyniku tablicy z Observable.fromPromise

Używam tutaj RxJS i nie mogę pozbyć się tego problemu z pozornie. rx.Observable .from([1,2,3,54,3,22,323,23,11,2]) .distinct() .subscribe(function next (x) { console.log('Next');

9Ciepło

3Odpowiedz

Jak wykonać wykonanie FlatMap na wątku tła

Używam Retrofit i RxJava do wykonywania niektórych zadań w tle. Kod wygląda następująco: public class MyLoader{ public Observable<MyData> getMyData(){ return setupHelper().flatMap(new Func1