interface Observable<T> {
Subscription subscribe(Observer<T> observer);
default Observable<T> filter(Predicate<T> fn) {
return observer -> {
Observer<T> obsT = new Observer<T>() {
@Override
public void onNext(T t) {
if (fn.test(t))
observer.onNext(t);
}
@Override
public void onError(Throwable t) {
observer.onError(t);
}
@Override
public void onComplete() {
observer.onComplete();
}
};
return this.subscribe(obsT);
};
}
}
上面代码中的this
指的是什么,有人可以帮忙吗...
最佳答案
它告诉当前的Observable
对象实例在处理完Filter
调用后调用它自己的Subscribe
方法并返回新的订阅
作为Observable
。
更具体地说,this
是指向正在执行当前作用域的对象实例的指针。
关于java - 关于 lambda 中 `this` 关键字的说明,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51086556/