rxjavaでobserverを使用しているときに実際に何が起こるのですか？

Question

私はRxJavaでオブザーバを使用している間に、実際に内部で何が起こっているのかを知りたいし、サブスクライバはどのようにオブザーバからすべてのデータストリームを取得しますか？

ありがとうございます。

Answer 1

あなたはRxJavaをObserver patternの極端な一般化として考えることができます。あなたは本質的にあなたが観察しているもの（観測可能なもの）でコールバックを登録します。観測可能なアイテムは、発信したいアイテムがあるときはいつでもonNext()と呼び出し、完了するとonComplete()となります。

残りのRxJava実装では、フロー制御、コールバックの構成、観測可能な状態での複数のコールバック、時間の歪み、異なる観測値の結合、スレッド管理をサポートしています。

実際に内部を知りたい場合は、コードを読むことができます。さらに重要なことは、RxJavaとリアクティブストリームの主要なアーキテクトと開発者であるDavid Karnokの物語を読むことができるということです。ここには、接続されたオブザーバブルの内部を記述するsample blogがあります。