rx-java

0熱度

1回答

我試圖找到一種並行執行請求的方法，並在每個observable完成時處理它們。儘管所有的觀察對象都給出了迴應，但所有事情都能正常工作，但在完成所有事情時我沒有辦法處理所有的錯誤。這是拉鍊運算符，它基本上並行地執行2名的請求的示例： Observable.zip( getObservable1() .onErrorResumeNext { errorThrowab

0熱度

1回答

用於RxJava的泛型Observable的TestScheduler

我開始使用TestScheduler。如果我用這個代替 @Test public void test1() throws Exception { //when TestScheduler scheduler = new TestScheduler(); TestObserver<Long> subscriber = new TestObserver<>();

0熱度

2回答

如何使用RxJava獲得來自Realm的物品列表的Observable？

我只有這個： public Observable<List<Movie>> getAll() { return Observable.just(Movie.class) .flatMap(t -> Observable.just(t) .doOnSubscribe(disposable -> realm.executeTransaction(realm1

-1熱度

2回答

RxJava Single.create無法指定線程

在initialize（）方法的下面工作很好，但它必須與其他調用在同一個io線程（ioScheduler）上工作。 fun initialize(): Single<Boolean> { return Single.create { callback -> callback.onSuccess(true) } } 我試圖將其更改爲下面的代碼： intern

0熱度

1回答

Asynctask status &&取消等效於RxJava2 Observable？

我想學習RxJava2，並將我的AsyncTasks轉換爲Observable。我有下面這段代碼，我試圖轉換。 if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask(); asyncTask.execute(input);

0熱度

2回答

將RxJava代碼正確轉換爲Kotlin

我正在學習Kotlin和RxJava。我在JAVA這樣的代碼： public class MainActivity extends AppCompatActivity { private HashMap<String, Object> cacheToInsertToDb; @Override protected void onCreate(Bundle savedInstanceSta

0熱度

2回答

RxJava 2運營商組合，只提供第一個值從一堆

這個想法是，當我多次呼叫publishSubject.onNext(someValue)我只需要得到一個值，如debounce運算符，但它提供了最後一個值，我需要跳過所有值除了第一組之外，直到我停止呼叫onNext()持續1秒。我試過使用類似throttleFirst(1000,TimeUnit.MILLISECONDS)的東西，但它不像debounce那樣工作，它只是在每次交付後使窗口和1秒後

0熱度

1回答

RxJava-JDBC中的批量插入

我有一個要插入數據庫的數據列表。我目前使用RxJava-JDBC的解決方案如下面的代碼片段所示： String sql_batch_insert = "insert into ... values(?, ?); Observable<List<..>> data = ...; data.flatMap(list -> Observable.from(list) .flat

2熱度

1回答

Observable.just VS單在RxJava

我是新來RxJava和RxAndroid，並試圖瞭解Observable.just和Single之間的差異。它看起來每個都被設計爲爲其觀察者發射一個項目。這裏是我的簡單的Android活動的有兩個按鈕的代碼。第一個按鈕創建一個Observable，第二個按鈕創建一個Single： findViewById(R.id.just).setOnClickListener(view -> Observa

0熱度

2回答

與多個用戶一次呼叫流的一部分？

我有用於套接字通信的自定義Rx適配器。在它之外，我觀察到Flowable帶有消息。然後我有一些經理處理每個消息，然後進一步發佈它。 fun observeSocket() = socketManager .observe() .doOnNext{ insideMessageHandler.handle(it) } 然後，我