rxjava-2.2.2.jar
登录
|
io.reactivex.rxjava2:rxjava:2.2.2
io
reactivex
SingleOnSubscribe.java
FlowableOperator.java
package-info.java
CompletableOnSubscribe.java
Notification.java
MaybeEmitter.java
Single.java
internal
queue
observers
disposables
subscribers
util
operators
maybe
mixed
completable
CompletableResumeNext.java
CompletableObserveOn.java
CompletableOnErrorComplete.java
CompletableFromPublisher.java
CompletableFromObservable.java
CompletableConcatIterable.java
CompletableFromCallable.java
CompletableSubscribeOn.java
CompletableCache.java
CompletableAmb.java
CompletableDoOnEvent.java
CompletableFromAction.java
CompletableEmpty.java
CompletableMerge.java
CompletableToFlowable.java
CompletableConcat.java
CompletableToSingle.java
CompletableLift.java
CompletableFromSingle.java
CompletableCreate.java
CompletableMergeDelayErrorIterable.java
CompletableDisposeOn.java
CompletableUsing.java
CompletableFromUnsafeSource.java
CompletableToObservable.java
CompletableNever.java
CompletableDefer.java
CompletableDelay.java
CompletableErrorSupplier.java
CompletableMergeDelayErrorArray.java
CompletableFromRunnable.java
CompletableTakeUntilCompletable.java
CompletableDetach.java
CompletableError.java
CompletableMergeIterable.java
CompletableConcatArray.java
CompletableMergeArray.java
CompletableTimer.java
CompletablePeek.java
CompletableTimeout.java
CompletableDoFinally.java
CompletableHide.java
flowable
parallel
observable
single
schedulers
fuseable
subscriptions
functions
SingleTransformer.java
Maybe.java
SingleOperator.java
observables
BackpressureStrategy.java
MaybeOperator.java
subjects
ObservableTransformer.java
plugins
SingleSource.java
ObservableConverter.java
MaybeObserver.java
observers
FlowableTransformer.java
disposables
Scheduler.java
ObservableEmitter.java
subscribers
parallel
CompletableSource.java
FlowableOnSubscribe.java
SingleObserver.java
BackpressureOverflowStrategy.java
MaybeOnSubscribe.java
schedulers
flowables
Emitter.java
MaybeConverter.java
SingleEmitter.java
exceptions
FlowableSubscriber.java
MaybeSource.java
Observer.java
SingleConverter.java
functions
processors
CompletableEmitter.java
FlowableConverter.java
CompletableConverter.java
annotations
CompletableTransformer.java
CompletableObserver.java
ObservableOnSubscribe.java
MaybeTransformer.java
ObservableOperator.java
CompletableOperator.java
Flowable.java
Completable.java
Observable.java
FlowableEmitter.java
ObservableSource.java
META-INF
CompletableDetach.java
清空
类结构
/** * Copyright (c) 2016-present, RxJava Contributors. * * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in * compliance with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software distributed under the License is * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See * the License for the specific language governing permissions and limitations under the License. */ package io.reactivex.internal.operators.completable; import io.reactivex.*; import io.reactivex.disposables.
Disposable
; import io.reactivex.internal.disposables.
DisposableHelper
; /** * Breaks the references between the upstream and downstream when the Completable terminates. * <p>History: 2.1.5 - experimental * @since 2.2 */ public final class
CompletableDetach
extends
Completable
{ final
CompletableSource
source
; public
CompletableDetach
(
CompletableSource
source
) { this.
source
=
source
; } @
Override
protected void
subscribeActual
(
CompletableObserver
observer
) {
source
.
subscribe
(new
DetachCompletableObserver
(
observer
)); } static final class
DetachCompletableObserver
implements
CompletableObserver
,
Disposable
{
CompletableObserver
downstream
;
Disposable
upstream
;
DetachCompletableObserver
(
CompletableObserver
downstream
) { this.
downstream
=
downstream
; } @
Override
public void
dispose
() {
downstream
= null;
upstream
.
dispose
();
upstream
=
DisposableHelper
.
DISPOSED
; } @
Override
public boolean
isDisposed
() { return
upstream
.
isDisposed
(); } @
Override
public void
onSubscribe
(
Disposable
d
) { if (
DisposableHelper
.
validate
(this.
upstream
,
d
)) { this.
upstream
=
d
;
downstream
.
onSubscribe
(this); } } @
Override
public void
onError
(
Throwable
e
) {
upstream
=
DisposableHelper
.
DISPOSED
;
CompletableObserver
a
=
downstream
; if (
a
!= null) {
downstream
= null;
a
.
onError
(
e
); } } @
Override
public void
onComplete
() {
upstream
=
DisposableHelper
.
DISPOSED
;
CompletableObserver
a
=
downstream
; if (
a
!= null) {
downstream
= null;
a
.
onComplete
(); } } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口