android - 在 RxJava 2 的 onComplete() 之前执行代码？

Question

我需要在 RxLifecycle 处理它之前关闭我的 observable 中的套接字连接。我怎样才能做到这一点？

Answer 1

如果你毕竟想做一个 Action ，就在订阅者取消订阅可观察对象之前，你可以使用运算符doOnUnsubscribe

@Test
public void testDoOnUnsubscribe() {
    Integer[] numbers = {0, 1, 2, 3, 4};
    Observable.from(numbers)
            .doOnUnsubscribe(() -> System.out.println("Last action must be done here"))
            .subscribe(number -> System.out.println("number:" + number),
                    System.out::println,
                    () -> System.out.println("End of pipeline"));
}

应该按这个顺序打印

number:0
number:1
number:2
number:3
number:4
End of pipeline
Last action must be done here