获取Flowable的内容

Flowable 是 RxJava 2.x 中的一个响应式流库，用于处理异步和基于事件的程序。获取 Flowable 的内容可以通过订阅它来实现。

在订阅 Flowable 之前，需要先创建一个 Flowable 对象，并定义它的行为。例如：

Flowable<Integer> flowable = Flowable.just(1, 2, 3, 4, 5);

上述代码创建了一个包含整数 1 到 5 的 Flowable 对象。

接下来，可以订阅这个 Flowable 对象来获取它的内容。例如：

flowable.subscribe(new Subscriber<Integer>() {
    @Override
    public void onSubscribe(Subscription s) {
        s.request(Long.MAX_VALUE);
    }

    @Override
    public void onNext(Integer integer) {
        System.out.println(integer);
    }

    @Override
    public void onError(Throwable t) {
        t.printStackTrace();
    }

    @Override
    public void onComplete() {
        System.out.println("Completed");
    }
});

上述代码中，订阅了之前创建的 Flowable 对象，并在回调方法中处理它发送的事件。在这个例子中，我们打印出每个整数，并在最后打印出 "Completed" 表示程序已经完成处理所有事件。

注意，在订阅 Flowable 时，需要传入一个 Subscriber 对象，并实现它的回调方法。在 onSubscribe() 方法中，需要调用 Subscription 对象的 request() 方法来请求全部事件。在 onNext() 方法中，处理每个事件的内容。在 onError() 方法中，处理错误情况。在 onComplete() 方法中，处理所有事件已经完成的情况。