タグ

関連タグで絞り込む (0)

  • 関連タグはありません

タグの絞り込みを解除

javaとrxjavaとprogrammingに関するastk_fのブックマーク (2)

  • RxJavaのレシピ:Androidのイベントをストリームに変換する | POSTD

    問題 まず、これから解決していく問題を先に述べます。 イベント(例えばOSの通知やBluetoothの状態)を受け取る部分がアプリ内に複数あり、各部分に関係がある時にのみその情報を受け取りたい場合を想像してみてください。 アプリの最初のクライアントが関心を持った時にのみイベントリスナーが登録され、誰も関心を持たなくなれば、すぐに登録を解除する必要がある。 新しいクライアントがイベントを購読する際、既存のクライアントに送信済みの前回のイベントを新しいクライアントがすぐに受け取れるようにして、全クライアントが常に同期するようにする。 今回の記事では、RxJavaの様々なコンポーネントを組み合わせることで、この問題を解決する道を探ろうと思います。題に入る前に、 Subject や Replay 、そして Connectable Observables などのコンセプトを理解しておいてください。

    RxJavaのレシピ:Androidのイベントをストリームに変換する | POSTD
  • 詳解RxJava:Scheduler、非同期処理、subscribe/unsubscribe - Qiita

    RxJavaで聞かれたり悩んだり、罠ったことを書き足していく予定です。 こちらもどうぞ: http://qiita.com/yuya_presto/items/152fa80d073d865cfc90 Scheduler、非同期処理 非同期でやるには?どこからが非同期で実行されるの? Observableの実装や叩いたOperator(map()やfilter()などのメソッド)によりますが、基的に現在のスレッド(subscribe()を呼び出したスレッド)で「同期的に」実行されます。 ドキュメントに Scheduler: This version of XXX does not operate by default on a particular Scheduler. と書かれているものは、現在のスレッドで実行されます from(): 現在のスレッドで実行されます Subject: o

    詳解RxJava:Scheduler、非同期処理、subscribe/unsubscribe - Qiita
  • 1