rx-java2

    0熱度

    1回答

    免責聲明:忽略使用此產品的生產應用程序可能會或可能不會通過審覈的事實。我只是想讓這個概念起作用。下面是我試圖執行的代碼,我試圖做的所有代碼(現在)都是初始化四個常量,並且在第三個常量上有困難。 let app = UIApplication.shared let statusBar = app.value(forKey: "statusBar") as AnyObject let foregr

    0熱度

    1回答

    如果我做這樣的事情: Observable.just(1) .flatMap( //inner chain Observable.just(2) .subscribeOn(Schedulers.newThread()) ) .map(// we are in the inner chain thread! //) .subscribeOn(Schedulers

    0熱度

    1回答

    現在,我想了解如何使用Realm與RxJava2。沒有很多信息。例如,我有一個簡單的查詢: CommentObject firstComments = realmForThisThread.where(CommentObject.class) .equalTo(CommentObject.COMMENT,comment).findFirst(); 如何獲得firstCommen

    0熱度

    4回答

    我想在一個序列中調用多個Rest Api,並讓每個響應Dto彼此不同。 請幫我擺脫這種情況,我怎樣才能在Android中調用這些Api使用Rx Java Observables。

    1熱度

    2回答

    Android,Retrofit,RxJava。請看這個例子調用: mcityService.signOut(signOutRequest) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(resp -> {

    0熱度

    1回答

    我有兩個Flowable列表 我需要將它們合併,應用一些函數並獲得Flowable列表 最初的Flowable列表表示來自DB 的數據,並且想法是當在DB中可以改變時可以改變組合列表以及投入都改變了。 我想拉鍊不是正確的方法,因爲它一旦工作完成它的工作,並不會繼續發出變化。 我的問題,這可能是拉鍊的替代,我可以結合2所列出,適用於一些功能,並繼續聽取更新 Flowable.zip(shopping

    0熱度

    1回答

    我有一個簡單的工作是使用GreenDao選擇數據。另外我想顯示ProgressWheel,但是這個作業阻止了UI線程。 showLoader(); DataManager.getInstance(this).getQuestions(0, 800) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedul

    0熱度

    3回答

    有沒有辦法在運行時更改Observable.interval週期? 有沒有辦法停止和恢復Observable.interval滴答? 有沒有辦法重置間隔時間? 其實我用下面的代碼做了一段時間爲永遠的動作,但我有在運行時間上沒有控制,我不得不停止,恢復,休息,並在運行時改變期。 Observable.interval(8, TimeUnit.SECONDS).observeOn(AndroidSch

    0熱度

    2回答

    我是RxJava的新手,所以我仍然試圖讓自己的頭靠近它。我有一個Observable代表一串按鈕點擊,所以它很熱。每次點擊該按鈕時,我都想做一些I/O。如果失敗,我想重複並嘗試再次執行該I/O,直到成功。這似乎是一個使用retry()或repeat()的好機會,但那些只能用於熱門的可觀察對象,而不是冷的。 下面是一些僞代碼來獲得在我想要做的事: buttonRequests .map(a

    0熱度

    1回答

    我有ViewPager兩頁,即熱門和全部。我試圖實現的只是推動項目,有熱門標籤真正到熱門而所有項目推到全部。 目前我有一個類用於PagerAdapter並傳遞頁面類型。如何過濾掉PublishSubject,以便每個頁面只顯示相應的必需項目。 我的觀察者都訂閱了單個PublishSubject,但是我想要在發射時過濾我的 。 如果問題不清楚,請發表評論。我會盡我所能來傳達這個問題。如果因爲找不到任