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
CompletableCreate.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 java.util.concurrent.atomic.
AtomicReference
; import io.reactivex.*; import io.reactivex.disposables.
Disposable
; import io.reactivex.exceptions.
Exceptions
; import io.reactivex.functions.
Cancellable
; import io.reactivex.internal.disposables.*; import io.reactivex.plugins.
RxJavaPlugins
; public final class
CompletableCreate
extends
Completable
{ final
CompletableOnSubscribe
source
; public
CompletableCreate
(
CompletableOnSubscribe
source
) { this.
source
=
source
; } @
Override
protected void
subscribeActual
(
CompletableObserver
observer
) {
Emitter
parent
= new
Emitter
(
observer
);
observer
.
onSubscribe
(
parent
); try {
source
.
subscribe
(
parent
); } catch (
Throwable
ex
) {
Exceptions
.
throwIfFatal
(
ex
);
parent
.
onError
(
ex
); } } static final class
Emitter
extends
AtomicReference
<
Disposable
> implements
CompletableEmitter
,
Disposable
{ private static final long
serialVersionUID
= -2467358622224974244L; final
CompletableObserver
downstream
;
Emitter
(
CompletableObserver
downstream
) { this.
downstream
=
downstream
; } @
Override
public void
onComplete
() { if (
get
() !=
DisposableHelper
.
DISPOSED
) {
Disposable
d
=
getAndSet
(
DisposableHelper
.
DISPOSED
); if (
d
!=
DisposableHelper
.
DISPOSED
) { try {
downstream
.
onComplete
(); } finally { if (
d
!= null) {
d
.
dispose
(); } } } } } @
Override
public void
onError
(
Throwable
t
) { if (!
tryOnError
(
t
)) {
RxJavaPlugins
.
onError
(
t
); } } @
Override
public boolean
tryOnError
(
Throwable
t
) { if (
t
== null) {
t
= new
NullPointerException
("onError called with null. Null values are generally not allowed in 2.x operators and sources."); } if (
get
() !=
DisposableHelper
.
DISPOSED
) {
Disposable
d
=
getAndSet
(
DisposableHelper
.
DISPOSED
); if (
d
!=
DisposableHelper
.
DISPOSED
) { try {
downstream
.
onError
(
t
); } finally { if (
d
!= null) {
d
.
dispose
(); } } return true; } } return false; } @
Override
public void
setDisposable
(
Disposable
d
) {
DisposableHelper
.
set
(this,
d
); } @
Override
public void
setCancellable
(
Cancellable
c
) {
setDisposable
(new
CancellableDisposable
(
c
)); } @
Override
public void
dispose
() {
DisposableHelper
.
dispose
(this); } @
Override
public boolean
isDisposed
() { return
DisposableHelper
.
isDisposed
(
get
()); } @
Override
public
String
toString
() { return
String
.
format
("%s{%s}",
getClass
().
getSimpleName
(), super.toString()); } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口