RxJava 2
我有以下两个有关如何使用skipUntil的示例:
此函数将lambda函数传递给skipUntil:
sourceSubject
.skipUntil<Int> {
triggerSubject.subscribe(it)
}
.subscribeBy { println(it) }
并且这个通过了观察者:
sourceSubject
.skipUntil(triggerSubject)
.subscribeBy { println(it) }
但是,我对方法签名感到困惑,因为它似乎只需要一个观察者,而我看不到lambda。只想知道为什么我可以通过观察者并将lambda传递给此函数
这是似乎只是显示传递给观察者的方法:
public final <U> Observable<T> skipUntil(ObservableSource<U> other) {
ObjectHelper.requireNonNull(other, "other is null");
return RxJavaPlugins.onAssembly(new ObservableSkipUntil<T, U>(this, other));
}
非常感谢
此功能称为SAM Conversions。它基本上意味着