RxJava/RxAndroid：ReplaySubject

痛定思痛。 2023-10-17 17:57 7阅读 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

RxJava/RxAndroid：ReplaySubject

发表评论取消回复

还没有评论，来说两句吧...

相关阅读