RxJava/RxAndroid：ReplaySubject 痛定思痛。 2023-10-17 17:57 8阅读 0赞 **RxJava/RxAndroid：ReplaySubject** import android.support.v7.app.AppCompatActivity; import android.os.Bundle; import android.util.Log; import io.reactivex.observers.DisposableObserver; import io.reactivex.subjects.ReplaySubject; public class MainActivity extends AppCompatActivity { private String TAG = "输出"; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); ReplaySubject mReplaySubject = ReplaySubject.create(128); mReplaySubject.subscribe(mDisposableObserver1); mReplaySubject.onNext(0); mReplaySubject.onNext(1); mReplaySubject.onNext(2); mReplaySubject.subscribe(mDisposableObserver2); } private DisposableObserver mDisposableObserver1 = new DisposableObserver<Integer>() { @Override public void onNext(Integer i) { Log.d(TAG, "onNext-1:" + i); } @Override public void onComplete() { Log.d(TAG, "onComplete-1"); } @Override public void onError(Throwable e) { Log.e(TAG, e.toString(), e); } }; private DisposableObserver mDisposableObserver2 = new DisposableObserver<Integer>() { @Override public void onNext(Integer integer) { Log.d(TAG, "onNext-2:" + integer); } @Override public void onError(Throwable e) { } @Override public void onComplete() { Log.d(TAG, "onComplete-2"); } }; } output: 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-1:0 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-1:1 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-1:2 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-2:0 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-2:1 01-23 17:16:15.802 5165-5165/zhangphil.book D/输出: onNext-2:2
还没有评论，来说两句吧...