rxjava-1.3.8.jar
登录
|
io.reactivex:rxjava:1.3.8
META-INF
rx
package-info.java
Notification.java
Single.java
internal
producers
observers
util
operators
OperatorMapPair.java
OnSubscribeOnAssemblySingle.java
OnSubscribeDelaySubscriptionWithSelector.java
OnSubscribeFlatMapSingle.java
OperatorToObservableSortedList.java
OperatorSkipWhile.java
SingleObserveOn.java
OperatorTakeWhile.java
SingleOnSubscribeUsing.java
OnSubscribeFromIterable.java
OperatorSubscribeOn.java
OnSubscribeDelaySubscriptionOther.java
SingleDelay.java
SingleOperatorZip.java
CompletableOnSubscribeMergeArray.java
OperatorIgnoreElements.java
OnSubscribeReduce.java
BlockingOperatorMostRecent.java
OnSubscribeSkipTimed.java
OperatorOnBackpressureLatest.java
OnSubscribeFlatMapCompletable.java
OperatorBufferWithStartEndObservable.java
OnSubscribeToObservableFuture.java
BlockingOperatorToFuture.java
OperatorWindowWithObservableFactory.java
OperatorZipIterable.java
OperatorSampleWithObservable.java
OperatorToObservableList.java
OnSubscribeTakeLastOne.java
OperatorSerialize.java
OnSubscribeRange.java
OperatorScan.java
OnSubscribeDetach.java
OperatorEagerConcatMap.java
OperatorDoAfterTerminate.java
OperatorBufferWithSize.java
CompletableOnSubscribeMerge.java
SingleFromCallable.java
OnSubscribeCollect.java
SingleTakeUntilObservable.java
CompletableFlatMapSingleToCompletable.java
CompletableOnSubscribeConcat.java
OperatorWithLatestFrom.java
package.html
OnSubscribeRedo.java
OperatorTimeInterval.java
OperatorAll.java
OnSubscribeFromCallable.java
OnSubscribePublishMulticast.java
OnSubscribeDoOnEach.java
OperatorTakeUntilPredicate.java
SingleLiftObservableOperator.java
EmptyObservableHolder.java
SingleTakeUntilSingle.java
SingleOnErrorReturn.java
OnSubscribeDelaySubscription.java
OperatorDebounceWithTime.java
SingleFromObservable.java
OnSubscribeTimeoutTimedWithFallback.java
OperatorDoOnUnsubscribe.java
BlockingOperatorNext.java
OperatorGroupByEvicting.java
OnSubscribeConcatMap.java
CompletableFromEmitter.java
OnSubscribeSwitchIfEmpty.java
OnSubscribeFromArray.java
OnSubscribeLift.java
SingleOperatorOnErrorResumeNext.java
OnSubscribeThrow.java
OperatorWindowWithObservable.java
OperatorSwitch.java
OnSubscribeJoin.java
SingleDoOnUnsubscribe.java
OperatorSkipLast.java
OperatorDematerialize.java
OnSubscribeCreate.java
OperatorZip.java
OnSubscribeToMap.java
OnSubscribeOnAssembly.java
OnSubscribeFlattenIterable.java
OnSubscribeMap.java
OperatorDoOnRequest.java
OperatorTimestamp.java
OperatorGroupBy.java
NeverObservableHolder.java
OperatorBufferWithSingleObservable.java
OnSubscribeFilter.java
OperatorWindowWithTime.java
OnSubscribeRefCount.java
OperatorObserveOn.java
CompletableOnSubscribeConcatArray.java
OperatorAny.java
SingleFromEmitter.java
CompletableOnSubscribeMergeDelayErrorIterable.java
OperatorDelayWithSelector.java
OnSubscribeTimerOnce.java
OperatorMapNotification.java
OperatorCast.java
BackpressureUtils.java
OperatorWindowWithStartEndObservable.java
CompletableOnSubscribeMergeDelayErrorArray.java
SingleToObservable.java
OnSubscribeTimeoutSelectorWithFallback.java
OnSubscribeSingle.java
OperatorSkipLastTimed.java
OperatorSkip.java
DeferredScalarSubscriber.java
SingleTimeout.java
NotificationLite.java
BufferUntilSubscriber.java
OperatorOnErrorResumeNextViaFunction.java
OperatorDistinctUntilChanged.java
OperatorThrottleFirst.java
OperatorOnBackpressureBuffer.java
OperatorSingle.java
SingleOnSubscribeMap.java
OperatorSkipUntil.java
OperatorTakeTimed.java
OperatorTakeLastTimed.java
OperatorUnsubscribeOn.java
OnSubscribeAutoConnect.java
OnSubscribeDefer.java
OperatorDistinct.java
OperatorWindowWithSize.java
OnSubscribeUsing.java
DeferredScalarSubscriberSafe.java
SingleFromFuture.java
OperatorDoOnSubscribe.java
OperatorDelay.java
OperatorTakeLast.java
OnSubscribeReduceSeed.java
OnSubscribeToMultimap.java
BlockingOperatorLatest.java
OperatorTakeUntil.java
OperatorSampleWithTime.java
CompletableOnSubscribeConcatIterable.java
SingleDoOnSubscribe.java
OnSubscribeTimerPeriodically.java
OperatorReplay.java
OperatorOnBackpressureDrop.java
SingleDoAfterTerminate.java
OperatorMulticast.java
OnSubscribeCombineLatest.java
OperatorPublish.java
CompletableOnSubscribeTimeout.java
OperatorBufferWithTime.java
OperatorTake.java
OnSubscribeAmb.java
SingleOnSubscribeDelaySubscriptionOther.java
OperatorWithLatestFromMany.java
SingleTakeUntilCompletable.java
OnSubscribeGroupJoin.java
OperatorRetryWithPredicate.java
BlockingOperatorToIterator.java
OperatorDebounceWithSelector.java
OperatorMaterialize.java
SingleOperatorCast.java
OperatorSequenceEqual.java
OperatorMerge.java
OnSubscribeOnAssemblyCompletable.java
CompletableOnSubscribeMergeIterable.java
SingleDoOnEvent.java
OperatorElementAt.java
OperatorAsObservable.java
README.md
CachedObservable.java
schedulers
subscriptions
Subscription.java
singles
observables
Producer.java
subjects
Subscriber.java
plugins
observers
SingleSubscriber.java
Scheduler.java
BackpressureOverflow.java
schedulers
Emitter.java
SingleEmitter.java
exceptions
Observer.java
subscriptions
functions
CompletableEmitter.java
annotations
Completable.java
CompletableSubscriber.java
Observable.java
SingleFromEmitter.java
清空
类结构
/** * Copyright 2016 Netflix, Inc. * * 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 rx.internal.operators; import java.util.concurrent.atomic.
AtomicBoolean
; import rx.*; import rx.
Single
.
OnSubscribe
; import rx.exceptions.
Exceptions
; import rx.functions.*; import rx.internal.subscriptions.*; import rx.plugins.
RxJavaHooks
; /** * Calls an action with a SingleEmitter instance for each individual subscribers that * generates a terminal signal (eventually). * * @param <T> the success value type */ public final class
SingleFromEmitter
<T> implements
OnSubscribe
<T> { final
Action1
<
SingleEmitter
<T>>
producer
; public
SingleFromEmitter
(
Action1
<
SingleEmitter
<T>>
producer
) { this.
producer
=
producer
; } @
Override
public void
call
(
SingleSubscriber
<? super T>
t
) {
SingleEmitterImpl
<T>
parent
= new
SingleEmitterImpl
<T>(
t
);
t
.
add
(
parent
); try {
producer
.
call
(
parent
); } catch (
Throwable
ex
) {
Exceptions
.
throwIfFatal
(
ex
);
parent
.
onError
(
ex
); } } static final class
SingleEmitterImpl
<T> extends
AtomicBoolean
implements
SingleEmitter
<T>,
Subscription
{ private static final long
serialVersionUID
= 8082834163465882809L; final
SingleSubscriber
<? super T>
actual
; final
SequentialSubscription
resource
;
SingleEmitterImpl
(
SingleSubscriber
<? super T>
actual
) { this.
actual
=
actual
; this.
resource
= new
SequentialSubscription
(); } @
Override
public void
unsubscribe
() { if (
compareAndSet
(false, true)) {
resource
.
unsubscribe
(); } } @
Override
public boolean
isUnsubscribed
() { return
get
(); } @
Override
public void
onSuccess
(T
t
) { if (
compareAndSet
(false, true)) { try {
actual
.
onSuccess
(
t
); } finally {
resource
.
unsubscribe
(); } } } @
Override
public void
onError
(
Throwable
t
) { if (
t
== null) {
t
= new
NullPointerException
(); } if (
compareAndSet
(false, true)) { try {
actual
.
onError
(
t
); } finally {
resource
.
unsubscribe
(); } } else {
RxJavaHooks
.
onError
(
t
); } } @
Override
public void
setSubscription
(
Subscription
s
) {
resource
.
update
(
s
); } @
Override
public void
setCancellation
(
Cancellable
c
) {
setSubscription
(new
CancellableSubscription
(
c
)); } } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口