Flowable 提前结束任务 - 使用 dispose() 方法

要提前结束 Flowable 任务，可以使用 Flowable 的 'dispose()' 方法。该方法会立即终止 Flowable 的执行，并且不会触发任何后续的事件。

下面是一个示例代码：

Flowable<Integer> flowable = Flowable.range(1, 10)
    .doOnNext(System.out::println)
    .doOnComplete(() -> System.out.println('Completed'));

Disposable disposable = flowable.subscribe();

// 在需要提前结束任务的地方调用 dispose() 方法
disposable.dispose();

在上面的例子中，我们创建了一个从 1 到 10 的 Flowable，并在每个元素和完成事件上打印日志。然后我们订阅了该 Flowable，并将返回的 Disposable 对象保存起来。最后，在需要提前结束任务的地方，我们调用了 'dispose()' 方法来终止 Flowable 的执行。

请注意，调用 'dispose()' 方法后，Flowable 将立即终止执行，并且不会触发任何后续的事件，包括完成事件。