Rxjava2系列：使用简化的Observer：Consumer

Posted 2022-12-16 zhangjin1120

上篇文章:RxJava2系列：rxjava2简单使用 中使用了Observer接口，Observer接口有4个方法。如果只想用onNext方法，另外3个方法：onSubscribe，onError，onComplete不想用的话，可以使用另外一个接口：Consumer。

从下图可以看出，subscribe方法在只传递一个Consumer类型的参数时，就是消费onNext方法。

示例代码：

import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.functions.Consumer;


public class ConsumerTest 
    public static void main(String[] args) 
        Observable<Integer> observable = Observable.create(
                new ObservableOnSubscribe<Integer>() 
                    @Override
                    public void subscribe(ObservableEmitter<Integer> e) throws Exception 
                        e.onNext(1);
                        e.onNext(2);
                        e.onNext(3);
                        e.onComplete();
                    
                );
        Consumer<Integer> consumer = new Consumer<Integer>() 
            @Override
            public void accept(Integer i) throws Exception 
                System.out.println("accept: " + i);
            
        ;
        observable.subscribe(consumer);
    

执行结果：

accept: 1
accept: 2
accept: 3