RxJava/RxAndroid : buffer(int count)

心已赠人 2023-10-17 17:54 21阅读 0赞

**RxJava/RxAndroid : buffer(int count)**

import android.support.v7.app.AppCompatActivity;
    import android.os.Bundle;
    import android.util.Log;
    
    import java.util.List;
    
    import io.reactivex.Observable;
    import io.reactivex.Observer;
    import io.reactivex.android.schedulers.AndroidSchedulers;
    import io.reactivex.disposables.Disposable;
    import io.reactivex.schedulers.Schedulers;
    
    public class MainActivity extends AppCompatActivity {
        private String TAG = "输出";
    
        private Observer<List<Integer>> mObserver = new Observer<List<Integer>>() {
            @Override
            public void onSubscribe(Disposable d) {
    
            }
    
            @Override
            public void onNext(List<Integer> list) {
                Log.d(TAG, "onNext");
                for (int i = 0; i < list.size(); i++) {
                    Log.d(TAG, "onNext:" + list.get(i));
                }
            }
    
            @Override
            public void onComplete() {
                Log.d(TAG, "onComplete");
            }
    
            @Override
            public void onError(Throwable e) {
                Log.e(TAG, e.toString(), e);
            }
        };
    
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
    
            Integer[] numbers = new Integer[]{0, 1, 2, 3, 4};
    
            Observable.fromArray(numbers)
                    .buffer(2)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeWith(mObserver);
        }
    }

output:

01-19 17:02:45.736 18276-18276/? D/输出: onNext
    01-19 17:02:45.736 18276-18276/? D/输出: onNext:0
    01-19 17:02:45.736 18276-18276/? D/输出: onNext:1
    01-19 17:02:45.736 18276-18276/? D/输出: onNext
    01-19 17:02:45.736 18276-18276/? D/输出: onNext:2
    01-19 17:02:45.736 18276-18276/? D/输出: onNext:3
    01-19 17:02:45.736 18276-18276/? D/输出: onNext
    01-19 17:02:45.736 18276-18276/? D/输出: onNext:4
    01-19 17:02:45.736 18276-18276/? D/输出: onComplete