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
flowable
parallel
observable
ObservableTakeUntil.java
BlockingObservableIterable.java
ObservableSwitchIfEmpty.java
ObservableSkipUntil.java
ObservableTimeoutTimed.java
ObservableElementAt.java
ObservableMergeWithSingle.java
ObservableRangeLong.java
ObservableTakeUntilPredicate.java
ObservableSequenceEqual.java
ObservableBufferExactBoundary.java
ObservableWindowBoundarySelector.java
ObservableReduceSeedSingle.java
ObservableAny.java
ObservableWindow.java
ObservableSampleTimed.java
ObservableFlatMapCompletableCompletable.java
ObservableBufferTimed.java
ObserverResourceWrapper.java
ObservableBuffer.java
ObservableToList.java
ObservablePublishSelector.java
ObservableTakeLastOne.java
ObservableReduceWithSingle.java
ObservableFlatMapCompletable.java
ObservableMap.java
ObservableFromPublisher.java
AbstractObservableWithUpstream.java
ObservableMaterialize.java
BlockingObservableNext.java
ObservableConcatWithSingle.java
ObservableCollectSingle.java
ObservableFromFuture.java
ObservableFilter.java
ObservableTimeInterval.java
ObservableFromUnsafeSource.java
ObservableAutoConnect.java
ObservableTimeout.java
ObservableRetryPredicate.java
ObservableDematerialize.java
ObservableAmb.java
ObservableRetryWhen.java
ObservableZip.java
ObservableWindowTimed.java
ObservableLastMaybe.java
BlockingObservableMostRecent.java
ObservableSkip.java
ObservableBlockingSubscribe.java
ObservableFromCallable.java
ObservableConcatWithCompletable.java
ObservableDoFinally.java
ObservableDebounceTimed.java
ObservableCountSingle.java
ObservableFromIterable.java
ObservableIgnoreElements.java
ObservableHide.java
ObservableCollect.java
ObservableGenerate.java
ObservableSingleSingle.java
ObservableFlattenIterable.java
ObservableCache.java
ObservableSerialized.java
ObservablePublish.java
ObservableRange.java
ObservableIgnoreElementsCompletable.java
ObservableUnsubscribeOn.java
ObservableUsing.java
ObservableOnErrorReturn.java
ObservableMergeWithMaybe.java
ObservableInterval.java
ObservableFlatMap.java
ObservableConcatMapEager.java
ObservableOnErrorNext.java
ObservableCreate.java
ObservableThrottleFirstTimed.java
ObservableWindowBoundary.java
ObservableNever.java
ObservableError.java
ObservableRetryBiPredicate.java
ObservableBufferBoundarySupplier.java
ObservableDelaySubscriptionOther.java
ObservableSwitchMap.java
ObservableMapNotification.java
ObservableTakeWhile.java
ObservableEmpty.java
ObservableDoOnEach.java
ObservableAll.java
ObservableTakeLast.java
ObservableRefCount.java
ObservableRepeatWhen.java
ObservableDoOnLifecycle.java
ObservableScan.java
ObservableElementAtSingle.java
ObservableSingleMaybe.java
ObservableRepeat.java
ObservableWindowBoundarySupplier.java
ObservableSkipLast.java
ObservableIntervalRange.java
ObservableObserveOn.java
ObservableRepeatUntil.java
ObservableConcatWithMaybe.java
ObservableGroupJoin.java
ObservableAllSingle.java
ObservableLastSingle.java
ObservableTimer.java
ObservableFromArray.java
ObservableElementAtMaybe.java
ObservableAnySingle.java
ObservableTake.java
ObservableCount.java
ObservableScalarXMap.java
ObservableToListSingle.java
ObservableSkipLastTimed.java
ObservableDistinctUntilChanged.java
ObservableDebounce.java
ObservableSequenceEqualSingle.java
ObservableTakeLastTimed.java
ObservableZipIterable.java
ObservableDefer.java
ObservableDistinct.java
BlockingObservableLatest.java
ObservableDelay.java
ObservableBufferBoundary.java
ObservableGroupBy.java
ObservableJoin.java
ObservableDetach.java
ObservableJust.java
ObservableFlatMapMaybe.java
ObservableReplay.java
ObservableCombineLatest.java
ObservableSkipWhile.java
ObservableWithLatestFromMany.java
ObservableMergeWithCompletable.java
ObservableLift.java
ObservableWithLatestFrom.java
ObservableDoAfterNext.java
ObservableSampleWithObservable.java
ObservableFlatMapSingle.java
ObservableInternalHelper.java
ObservableScanSeed.java
ObservableReduceMaybe.java
ObservableThrottleLatest.java
ObservableSubscribeOn.java
ObservableConcatMap.java
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
ObservableSwitchIfEmpty.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.observable; import io.reactivex.*; import io.reactivex.disposables.
Disposable
; import io.reactivex.internal.disposables.
SequentialDisposable
; public final class
ObservableSwitchIfEmpty
<T> extends
AbstractObservableWithUpstream
<T, T> { final
ObservableSource
<? extends T>
other
; public
ObservableSwitchIfEmpty
(
ObservableSource
<T>
source
,
ObservableSource
<? extends T>
other
) { super(
source
); this.
other
=
other
; } @
Override
public void
subscribeActual
(
Observer
<? super T>
t
) {
SwitchIfEmptyObserver
<T>
parent
= new
SwitchIfEmptyObserver
<T>(
t
,
other
);
t
.
onSubscribe
(
parent
.
arbiter
);
source
.
subscribe
(
parent
); } static final class
SwitchIfEmptyObserver
<T> implements
Observer
<T> { final
Observer
<? super T>
downstream
; final
ObservableSource
<? extends T>
other
; final
SequentialDisposable
arbiter
; boolean
empty
;
SwitchIfEmptyObserver
(
Observer
<? super T>
actual
,
ObservableSource
<? extends T>
other
) { this.
downstream
=
actual
; this.
other
=
other
; this.
empty
= true; this.
arbiter
= new
SequentialDisposable
(); } @
Override
public void
onSubscribe
(
Disposable
d
) {
arbiter
.
update
(
d
); } @
Override
public void
onNext
(T
t
) { if (
empty
) {
empty
= false; }
downstream
.
onNext
(
t
); } @
Override
public void
onError
(
Throwable
t
) {
downstream
.
onError
(
t
); } @
Override
public void
onComplete
() { if (
empty
) {
empty
= false;
other
.
subscribe
(this); } else {
downstream
.
onComplete
(); } } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口