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
CompletableToSingle.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.
Callable
; import io.reactivex.*; import io.reactivex.disposables.
Disposable
; import io.reactivex.exceptions.
Exceptions
; public final class
CompletableToSingle
<T> extends
Single
<T> { final
CompletableSource
source
; final
Callable
<? extends T>
completionValueSupplier
; final T
completionValue
; public
CompletableToSingle
(
CompletableSource
source
,
Callable
<? extends T>
completionValueSupplier
, T
completionValue
) { this.
source
=
source
; this.
completionValue
=
completionValue
; this.
completionValueSupplier
=
completionValueSupplier
; } @
Override
protected void
subscribeActual
(final
SingleObserver
<? super T>
observer
) {
source
.
subscribe
(new
ToSingle
(
observer
)); } final class
ToSingle
implements
CompletableObserver
{ private final
SingleObserver
<? super T>
observer
;
ToSingle
(
SingleObserver
<? super T>
observer
) { this.
observer
=
observer
; } @
Override
public void
onComplete
() { T
v
; if (
completionValueSupplier
!= null) { try {
v
=
completionValueSupplier
.
call
(); } catch (
Throwable
e
) {
Exceptions
.
throwIfFatal
(
e
);
observer
.
onError
(
e
); return; } } else {
v
=
completionValue
; } if (
v
== null) {
observer
.
onError
(new
NullPointerException
("The value supplied is null")); } else {
observer
.
onSuccess
(
v
); } } @
Override
public void
onError
(
Throwable
e
) {
observer
.
onError
(
e
); } @
Override
public void
onSubscribe
(
Disposable
d
) {
observer
.
onSubscribe
(
d
); } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口