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
BlockingFirstObserver.java
DisposableLambdaObserver.java
BasicFuseableObserver.java
ForEachWhileObserver.java
BasicIntQueueDisposable.java
FutureObserver.java
LambdaObserver.java
ConsumerSingleObserver.java
EmptyCompletableObserver.java
BlockingLastObserver.java
CallbackCompletableObserver.java
BlockingBaseObserver.java
InnerQueuedObserver.java
SubscriberCompletableObserver.java
DeferredScalarObserver.java
BiConsumerSingleObserver.java
FutureSingleObserver.java
BasicQueueDisposable.java
InnerQueuedObserverSupport.java
DeferredScalarDisposable.java
ResumeSingleObserver.java
QueueDrainObserver.java
BlockingObserver.java
BlockingMultiObserver.java
disposables
subscribers
util
operators
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
EmptyCompletableObserver.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.observers; import java.util.concurrent.atomic.
AtomicReference
; import io.reactivex.
CompletableObserver
; import io.reactivex.disposables.
Disposable
; import io.reactivex.exceptions.
OnErrorNotImplementedException
; import io.reactivex.internal.disposables.
DisposableHelper
; import io.reactivex.observers.
LambdaConsumerIntrospection
; import io.reactivex.plugins.
RxJavaPlugins
; public final class
EmptyCompletableObserver
extends
AtomicReference
<
Disposable
> implements
CompletableObserver
,
Disposable
,
LambdaConsumerIntrospection
{ private static final long
serialVersionUID
= -7545121636549663526L; @
Override
public void
dispose
() {
DisposableHelper
.
dispose
(this); } @
Override
public boolean
isDisposed
() { return
get
() ==
DisposableHelper
.
DISPOSED
; } @
Override
public void
onComplete
() { // no-op
lazySet
(
DisposableHelper
.
DISPOSED
); } @
Override
public void
onError
(
Throwable
e
) {
lazySet
(
DisposableHelper
.
DISPOSED
);
RxJavaPlugins
.
onError
(new
OnErrorNotImplementedException
(
e
)); } @
Override
public void
onSubscribe
(
Disposable
d
) {
DisposableHelper
.
setOnce
(this,
d
); } @
Override
public boolean
hasCustomOnError
() { return false; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口