那個RxJava(六)的程式碼BehaviorSubject的程式碼找不到了，直接更新到七了哈！

package com.example.acer.rxjavatest;

import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;
import android.widget.EditText;

import rx.Observer;
import rx.subjects.ReplaySubject;

public
 
 class MainActivity extends AppCompatActivity {

    private ReplaySubject mMp;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        mMp = ReplaySubject.create();

    }

    public
 
 void click(View view) {
        mMp.subscribe(new Observer<String>() {

            @Override
            public void onCompleted() {
                Log.i("zhang_xin", "完成");
            }

            @Override
            public void onError(Throwable e) {
                Log.i("zhang_xin"
 
, "異常");
            }

            @Override
            public void onNext(String s) {
                Log.i("zhang_xin", "收到的訊息：" + s);
            }
        });

    }

    public void send(View view) {
        EditText et_content= (EditText) findViewById(R.id.et_content);
        String content=et_content.getText().toString().trim();
        mMp.onNext(content);
    }
}

我們點選訂閱，傳送訊息！

我們傳送兩條訊息，第一條是aaa,第二條是bbb;觀察者都可以收到
，那麼下面我有新的觀察者訂閱，點選“我要訂閱按鈕”我們發現先前兩條訊息(aaa,bbb)自動（不點擊發送訊息按鈕）傳送到了新訂閱的觀察者！如下圖所示：

總結：ReplaySubject快取了我們所有的訊息，一旦新的觀察者訂閱了，會立馬將快取的所有的訊息傳送給相應的觀察者；這樣做的好處是保證所有訂閱我的觀察者都能收到之前的錯過的訊息；快取的數量可以指定，預設的快取數量是16個；ReplaySubject通過ArrayList做快取