传递观察者并将lambda传递给skipUntil方法

问题描述 投票:0回答:1
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));
    }

非常感谢

kotlin rx-java2
1个回答
0
投票

此功能称为SAM Conversions。它基本上意味着

© www.soinside.com 2019 - 2024. All rights reserved.