rx-android

0熱

1答えて

非同期RxJavaサブスクリプションがまだスローされていますNetworkOnMainThreadException

同じ質問を解決するためにここで他の答えを見た後、ソリューションが動作しているように見えません。ここに私が得ているエラーがあります。私はnewThread()に私のRxJava実装を、mainThread()にオブザーバを持っています。私の最初の観測はObservable>を放出しています。私はflatMapObservableを使ってそれを反復しており、個々のニュース項目をObservableと

0熱

1答えて

Rx Android：最後に計算された値を計算し返すために呼び出しをデバウンス

Rx Androidが新しくなった。私はスロットルのようなオペレータを参照してください& debounce;私はそれを私のシナリオで効果的に使用する方法を理解することはできません。私のAPPではいくつかのスレッドが実行されているため、グローバルな状態がいくつか更新され、高価な計算を実行するよう要求されます。計算を別のスレッドで実行する必要があります。呼び出し側スレッドは、Observableを

3熱

1答えて

Retrofit observableは一度しか動作しません

私は、デフォルトで、改造によって作成された観測値は「冷たい」観測値であることを理解します。あなたが期待するように私は、onNextonErroronCompleteコールバックを受信 public class LoginUseCase extends Subscriber<Profile> { public void logIn(String username, String passw

0熱

1答えて

リピート可観察可能なリクエスト

私は、データを取得し終えるまで、サーバーからデータを取得するリクエストを作成しようとしています。問題はこれです、レスポンスには21Data perPageがあります。しかし、次のページがあるかどうかを知るメタタグがあります。だから、私はnextPage == totalPageまで引っ張ることができます。 public static Observable<LgaListResponse> getP

8熱

2答えて

Rx - onNext（）を受信した後に自動的に退会する方法は？

onNext（）の受信後に自動的に退会する方法は？今の私はこのコードを使用します。 rxObservable .compose(bindToLifecycle()) // unsubscribe automatically in onPause() if method was called in onResume() .subscribe(new Subscriber<Object>() {

7熱

1答えて

RxAndroidBleは持続的な接続を維持+書き込み/通知処理

私はBluetooth Low Energyに関する特定の要件を持つAndroidアプリケーションを構築しています。書き込み専用の特性に書き込む必要があり、別の通知特性で応答を受け取る必要があります。多くの多くのアクティビティでそれを行う必要があります。第1の特性に関する要求を送信し、第2の特性に対する応答を待ってから別の要求に進むRx方法はありますか？また、RxAndroidBleのインスタ

2熱

1答えて

RxJava：Publish subject doOnSubscribeが呼び出されない

オブザーバーがPublishSubjectにサブスクライブするときに特定のアクションが実行される単純なシナリオを実装したいと思います。私はこのようにそれを実装： PublishSubject<String>publishSubject=PublishSubject.create(); publishSubject.doOnSubscribe(new Action0() {

3熱

2答えて

同時に2つのBLEデバイスから効率的に温度を読み取るにはどうすればよいですか？

まず、RxAndroidBLEライブラリを使用してBLE接続を管理しています。私は2つのSensorTag devicesを持っていて、同時に両方から温度を読みたいと思います。たとえば、両方のデバイスの温度を正確に500msごとに読み取って、2つのTextViewでユーザーに表示したいとします。私のアプリは現在、正常にこのようなBLEデバイスの両方に接続します。 @OnClick(R.id.c

1熱

1答えて

RxJava：Observableを変更せずにObservableにする

RxJavaの新機能ですが、私はそれを学びたいと思っています。しかし、この場合、単純なコールバックモデルを使用して変更できないコードがあります。しかし、コールバックは直接呼び出されず、パラメータ化できませんが、Observablesを使用したいと考えています。基本的な例は、observableを返し、バックグラウンド操作を開始するmyFunc（）を呼び出します。そのバックグラウンド操作は、myCa

1熱

1答えて

rxJava Observer.onNextが2回目に呼び出されない

rxJavaを使用してデータベースからデータを取得し、それをrecyclerviewに表示します。関連するコードは function updateUI(){ ContactsLab contactsLab = ContactsLab.get(getActivity()); Subscription sub = contactsLab.getContactList().subsc