package com.rp.sec04Operators;

import com.rp.coureutil.Util;
import reactor.core.publisher.Flux;

public class SwitchIfEmptyOperator {
    public static void main(String[] args) {
        getOrderNumber()
                .filter(i->i>10)
                .switchIfEmpty(fallBack())
                .subscribe(Util.subscriber());
    }
    private static Flux<Integer> getOrderNumber(){
        return Flux.range(1,10);
    }
    private static Flux<Integer> fallBack(){
        return Flux.range(100,200);
    }
}