RxJava学習過程

RxJavaも長い間火をつけて、ネット上で紹介した博文も多くて、ここで自分の勉強したいくつかの理解と心得を謹んで記録して、いくつかの地方の言うことが必ずしも正しいとは限らないかもしれません.謹んでこの記録にすぎない.まずAndroid開発者のRxJavaの詳細、頭の鬼に友鎖を添付します.再度声明する.博文は私個人の理解を代表して、もし子弟を誤認したら、一切責任を負いません.もちろん、私のこのブログを見る人がどれだけいるかはわかりませんが、ここでナルシストしてみましょう.
RxJavaは観察者モードを採用し,インタフェース向けにプログラミングし,観察者が常に観察者に注意することなく,観察者が変化を観察した後に観察者がすぐに反応できるようにコールバックを利用した.最近ますますインタフェースというものが好きになってきて、インタフェースで書かれたコードを使って、自分がかっこいいと思っています.~.
今日RxJavaを始めたばかりで、まずRxの最も基本的ないくつかの知識点を学びました.Obserable(被観察者)、Subsciber(観察者)は、被観察者がどんな風に吹かれても観察者がメッセージを受け、措置を取ることができると記録しています.コードレベルのコードは具体的にどのように書きますか.
1.観察者を生成する
方法1:

rx.Observable<String> observable = rx.Observable.create(new rx.Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> subscriber) {
            subscriber.onNext("hello world");
        }
    });

方式2:

rx.Observable<String> observable1= rx.Observable.just("hello world");

この2つの方法はここで効果は等価です.ただしjustメソッドではパラメータ生成のObservableとdef方式で使用されるObservableの違いに注意し,具体的には次のブログを参照する.
2.観察者を生成する:

 rx.Subscriber<String> subscriber1 = new Subscriber<String>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(String s) {
            Log.v("TAG", s);
        }
    };

3.両者を百年の好に結ぶ.

observable.subscribe(subscriber1);

実行すると、「hello world」の印刷が得られます.
あるいは被観察者は1つの行動のみを観察されてもよいし、subscribeは他のパラメータの種類の方法を提供している.例えば、上記の被観察者を使用しているが、現在はそのonNext行動のみを傍受している.次のようになります.

 Action1<String> mOnNextAction = new Action1<String>() {
        @Override
        public void call(String s) {
            Log.v("TAG", s);
        }
    };
    observable1.subscribe(mOnNextAction);

このように運転した結果も同じです.同様にsubscribe法はonNext,onCompleted,onErrorの3つのActionにそれぞれ対応するリロードを提供し,対応順序が正しいかどうか,忘れ,保証できない.
最後に観察者を縛ることを忘れないでください.

if (subscriber.isUnsubscribed()){
        subscriber.unsubscribe();
    }

OK、今日はここまで书いて、后ろのノートは勉强するにつれて増えて、寝て、叫んで~