rxjava2 (109)


android - デバイスパブリックIPを決定する

android - デバイスパブリックIPを決定する

どのように私はアンドロイドデバイスのパブリックIPアドレスを取得することができる誰も知っていますか? 私はサーバーソケットを走ろうとしています(単純なp2pで実験しています)。 これには、ローカルとリモートの各ユーザにパブリックIPを通知する必要があります。 私はこのスレッドを見つけたどのようにコードからデバイスのIPアドレスを取得するには? これには、IPを取得する方法を示すアーティクル(…


rxjava-androidを使用する際の問題

私はgradleと一緒に使っているプロジェクトでRxjavaを使っています。 コンパイルエラーはありませんが、プロジェクトを実行するとアプリケーションがクラッシュします。 12-01 14:40:41.553 1015-1015/? I/dalvikvm﹕ Could not find method rx.Subscription.unsubscribe, referenced from…


RxJava:依存関係のあるオブザーバブルを複数作成し、最後にすべての結果を収集する方法は?

私はRxJavaを学習しています。最初の実験として、RxJavaを使用して非同期性を改善するために、 このコードの最初のrun()メソッドでコードを書き直そうとしています(Netflixのブログで RxJavaの問題を解決することができます)残りのコードに進む前に最初のFuture( f1.get())の結果を待つことはありません。 f3はf1依存する。 私はこれを処理する方法を参照してく…


RxJavaのデカルト積

rxjavaで2つの観測量のデカルト積を取得することは可能ですか? このようなもの: A-> 1,2,3 B-> a,b A x B->(1, a),(1, b),(2, a),(2, b),(3, a),(3, b)…



android - OkHttp/RetrofitでHTTPリクエストを再試行する方法は?

AndroidプロジェクトでRetrofit/OkHttp(1.6)を使用しています。 私は、いずれかのリクエスト再試行メカニズムが組み込まれているとは思いません。 さらに検索すると、OkHttpがサイレントリトライをしているようです。 私は自分の接続(HTTPまたはHTTPS)のいずれにも起こっているとは思わない。 okclientで再試行を設定するには? 今のところ、私は例外をキ…


rx java - RxJavaでのフォールバック観測量

RxJavaを使用しているときに空の結果に対して単純なObservableフォールバックシステムを実現するためのより良い方法を探しています。 考え方は、データのセットに対するローカルクエリがゼロアイテムになる場合、代わりにフォールバッククエリ(ネットワークコールか何か他のものかもしれません)がなされるべきであるということです。 現在、私のコードは次のもので構成されています。 Observabl…


android - スクエアのわかりました。 ダウンロードの進行状況

square`のOkHttpを使用しているときにダウンロードファイルの進行状況を取得する方法はありますか? Recipes解決策が見つかりませんでした。 非同期にコンテンツを取得できるCallクラスがありますが、現在の進行状況を取得する方法はありません。…


java - onNext()で何も渡さないObservable

Observableが必要なのは、たとえばonNext()で何も渡す必要のないシステムクロックを提供するためです。 私はそれを可能にする署名を見つけることができませんでした。 確かに、私は任意のオブジェクトを使用してnullを渡すことができますが、それはあまり意味がありません。 だから私の質問は、それを行う良い方法があるかどうかです。 Observable.create(new Observ…


rx java - RxJavaでページングを処理する方法は?

私はネットワークリクエストのためにRxjavaを使うためにアンドロイドアプリを変換することを検討しています。 私は現在、次のようなWebサービスにアクセスしています: getUsersByKeyword(String query, int limit, int offset) 私が理解しているように、Observablesは「プル」インターフェースではなく「プッシュ」です。 だからここで私は…


AndroidでRxJavaとRetrofitを使ってリストを処理する

私は(順番に、非同期に)作るためのAPI呼び出しをいくつか持っており、それらのいくつかはリストを返します。 私のAPIインターフェイスは以下の通りです。 @GET("/users/settings") Observable<UserWrapper> getUserSettings(); @GET("/{username}/collections") Observable<List<Item>>…




rxjava android observable single rxandroid retrofit kotlin subscribe 入門 retrofit2