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
MaybeLift.java
MaybeFlatMapIterableObservable.java
MaybeToObservable.java
MaybeUnsubscribeOn.java
MaybeSwitchIfEmpty.java
MaybeTimeoutMaybe.java
MaybeCallbackObserver.java
MaybeFromCompletable.java
MaybeIsEmpty.java
MaybeFlatMapNotification.java
MaybeOnErrorNext.java
MaybeOnErrorComplete.java
MaybeDoAfterSuccess.java
MaybePeek.java
MaybeDetach.java
MaybeDoFinally.java
MaybeConcatArray.java
MaybeUsing.java
MaybeFromCallable.java
MaybeFromRunnable.java
MaybeZipArray.java
MaybeIsEmptySingle.java
MaybeDelayOtherPublisher.java
MaybeDoOnEvent.java
MaybeDelayWithCompletable.java
MaybeToFlowable.java
MaybeHide.java
MaybeCache.java
MaybeUnsafeCreate.java
MaybeFlatten.java
MaybeDelaySubscriptionOtherPublisher.java
MaybeEmpty.java
MaybeDefer.java
MaybeFlatMapCompletable.java
MaybeObserveOn.java
MaybeZipIterable.java
MaybeIgnoreElement.java
MaybeOnErrorReturn.java
MaybeAmb.java
MaybeFlatMapSingle.java
MaybeSwitchIfEmptySingle.java
MaybeFlatMapBiSelector.java
MaybeContains.java
MaybeJust.java
MaybeFlatMapIterableFlowable.java
MaybeIgnoreElementCompletable.java
MaybeSubscribeOn.java
MaybeFromFuture.java
MaybeFromAction.java
MaybeCreate.java
MaybeMergeArray.java
MaybeErrorCallable.java
MaybeTimer.java
MaybeTakeUntilMaybe.java
MaybeFlatMapSingleElement.java
MaybeToSingle.java
MaybeFromSingle.java
MaybeConcatArrayDelayError.java
MaybeFilter.java
MaybeNever.java
MaybeTimeoutPublisher.java
AbstractMaybeWithUpstream.java
MaybeMap.java
MaybeConcatIterable.java
MaybeError.java
MaybeEqualSingle.java
MaybeTakeUntilPublisher.java
MaybeToPublisher.java
MaybeCount.java
MaybeDelay.java
MaybeFilterSingle.java
mixed
completable
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
MaybeIgnoreElementCompletable.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.maybe; import io.reactivex.*; import io.reactivex.disposables.
Disposable
; import io.reactivex.internal.disposables.
DisposableHelper
; import io.reactivex.internal.fuseable.
FuseToMaybe
; import io.reactivex.plugins.
RxJavaPlugins
; /** * Turns an onSuccess into an onComplete, onError and onComplete is relayed as is. * * @param <T> the value type */ public final class
MaybeIgnoreElementCompletable
<T> extends
Completable
implements
FuseToMaybe
<T> { final
MaybeSource
<T>
source
; public
MaybeIgnoreElementCompletable
(
MaybeSource
<T>
source
) { this.
source
=
source
; } @
Override
protected void
subscribeActual
(
CompletableObserver
observer
) {
source
.
subscribe
(new
IgnoreMaybeObserver
<T>(
observer
)); } @
Override
public
Maybe
<T>
fuseToMaybe
() { return
RxJavaPlugins
.
onAssembly
(new
MaybeIgnoreElement
<T>(
source
)); } static final class
IgnoreMaybeObserver
<T> implements
MaybeObserver
<T>,
Disposable
{ final
CompletableObserver
downstream
;
Disposable
upstream
;
IgnoreMaybeObserver
(
CompletableObserver
downstream
) { this.
downstream
=
downstream
; } @
Override
public void
onSubscribe
(
Disposable
d
) { if (
DisposableHelper
.
validate
(this.
upstream
,
d
)) { this.
upstream
=
d
;
downstream
.
onSubscribe
(this); } } @
Override
public void
onSuccess
(T
value
) {
upstream
=
DisposableHelper
.
DISPOSED
;
downstream
.
onComplete
(); } @
Override
public void
onError
(
Throwable
e
) {
upstream
=
DisposableHelper
.
DISPOSED
;
downstream
.
onError
(
e
); } @
Override
public void
onComplete
() {
upstream
=
DisposableHelper
.
DISPOSED
;
downstream
.
onComplete
(); } @
Override
public boolean
isDisposed
() { return
upstream
.
isDisposed
(); } @
Override
public void
dispose
() {
upstream
.
dispose
();
upstream
=
DisposableHelper
.
DISPOSED
; } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口