响应式流的创建方式

1、just方式创建响应式流

public static void main(String[] args) {
    // 创建响应式流
    Observable<String> just = Observable.just("1", "2", "3", "4", "5");
    just.subscribe(
        item -> System.out.println("下一个元素：" + item),
        ex -> System.err.println("异常信息：" + ex.getMessage()),
        () -> System.out.println("流结束")
    );
}

2、通过数组创建响应式流

    public static void main(String[] args) {
        Observable<Integer> integerObservable = Observable.fromArray(new Integer[]{1,2,3,4,5});
        integerObservable.subscribe(
                System.out::println,
                System.err::println,
                () -> System.out.println("流结束")
        );
    }

3、通过集合创建响应式流

public static void main(String[] args) {
    var list = new ArrayList<>();
    for (int i = 0; i < 10; i++) {
        list.add(i);
    }
    //Observable<Object> objectObservable = Observable.fromIterable(Collections.emptyList());
    Observable<Object> objectObservable = Observable.fromIterable(list);
    objectObservable.subscribe(
        System.out::println,
        System.err::println
    );
}

3、通过Callable创建响应式流

public static void main(String[] args) {
    Observable.fromCallable(() -> "hello")
        .subscribe(System.out::println);
}

�

3、通过线程池提交任务创建响应式流

public static void main(String[] args) {
    Future<String> future = Executors.newCachedThreadPool().submit(() -> "hello");
    // 从callable创建响应式流，订阅，消费
    Observable.fromFuture(future).subscribe(System.out::println);
}