io.reactivex.internal.disposables.DisposableHelper#validate ( )源码实例Demo

下面列出了io.reactivex.internal.disposables.DisposableHelper#validate ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： RxJava2Debug 文件： CompletableOnAssembly.java

@Override
public void onSubscribe(Disposable d) {
    if (DisposableHelper.validate(this.d, d)) {
        this.d = d;

        actual.onSubscribe(this);
    }
}

源代码2 项目： RxJava2Debug 文件： MaybeOnAssembly.java

@Override
public void onSubscribe(Disposable d) {
    if (DisposableHelper.validate(this.d, d)) {
        this.d = d;

        actual.onSubscribe(this);
    }
}

源代码3 项目： RxJava2Debug 文件： SingleOnAssembly.java

@Override
public void onSubscribe(Disposable d) {
    if (DisposableHelper.validate(this.d, d)) {
        this.d = d;

        actual.onSubscribe(this);
    }
}

源代码4 项目： akarnokd-misc 文件： SingleFlatMapIterableFlowable.java

@Override
public void onSubscribe(Disposable d) {
    if (DisposableHelper.validate(this.d, d)) {
        this.d = d;

        actual.onSubscribe(this);
    }
}

源代码5 项目： akarnokd-misc 文件： SingleFlatMapIterableObservable.java

@Override
public void onSubscribe(Disposable d) {
    if (DisposableHelper.validate(this.d, d)) {
        this.d = d;

        actual.onSubscribe(this);
    }
}

源代码6 项目： armeria 文件： RequestContextSingleObserver.java

@Override
public void onSubscribe(Disposable d) {
    if (!DisposableHelper.validate(disposable, d)) {
        return;
    }
    disposable = d;
    try (SafeCloseable ignored = assemblyContext.push()) {
        actual.onSubscribe(this);
    }
}

源代码7 项目： armeria 文件： RequestContextMaybeObserver.java

@Override
public void onSubscribe(Disposable d) {
    if (!DisposableHelper.validate(disposable, d)) {
        return;
    }
    disposable = d;
    try (SafeCloseable ignored = assemblyContext.push()) {
        actual.onSubscribe(this);
    }
}

源代码8 项目： armeria 文件： RequestContextCompletableObserver.java

@Override
public void onSubscribe(Disposable d) {
    if (!DisposableHelper.validate(disposable, d)) {
        return;
    }
    disposable = d;
    try (SafeCloseable ignored = assemblyContext.push()) {
        actual.onSubscribe(this);
    }
}

方法所在类

io.reactivex.internal.disposables.DisposableHelper