java - Rx Java 只订阅一个发出的项目

Question

我有一个包含实际数据的 BehaviorSubject 数据(或者可能什么都没有，如果没有向它发送任何数据的话)。我只想订阅它发出的一个项目，即当前观察到的值或第一个从其他地方传递给它的值。我目前正在通过以下方式进行:

Subscription firstItemSubscription = data.subscribe(item -> {
    firstItemSubscription.unsubscribe();
    processItem(item);
});

有没有我可以使用的运算符或转换器？或者可能有完全不同的、更多的 Rx 方法可以让我做我想做的事？

Answer 1

是的，只需要使用take(1)

Observable observable = //some observable

observable.take(1).subscribe(/* do your thing */);