Package rx.internal.operators
Class OnSubscribeGroupJoin.ResultManager
- java.lang.Object
-
- rx.internal.operators.OnSubscribeGroupJoin.ResultManager
-
- All Implemented Interfaces:
Subscription
final class OnSubscribeGroupJoin.ResultManager extends java.lang.Object implements Subscription
Manages sub-observers and subscriptions.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
OnSubscribeGroupJoin.ResultManager.LeftDurationObserver
Observe left duration and apply termination.(package private) class
OnSubscribeGroupJoin.ResultManager.LeftObserver
Observe the left source.(package private) class
OnSubscribeGroupJoin.ResultManager.RightDurationObserver
Observe right duration and apply termination.(package private) class
OnSubscribeGroupJoin.ResultManager.RightObserver
Observe the right source.
-
Field Summary
Fields Modifier and Type Field Description (package private) RefCountSubscription
cancel
(package private) CompositeSubscription
group
(package private) java.lang.Object
guard
(package private) boolean
leftDone
Guarded by guard.(package private) int
leftIds
Guarded by guard.(package private) java.util.Map<java.lang.Integer,Observer<T2>>
leftMap
Guarded by guard.(package private) boolean
rightDone
Guarded by guard.(package private) int
rightIds
Guarded by guard.(package private) java.util.Map<java.lang.Integer,T2>
rightMap
Guarded by guard.(package private) Subscriber<? super R>
subscriber
-
Constructor Summary
Constructors Constructor Description ResultManager(Subscriber<? super R> subscriber)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
complete(java.util.List<Observer<T2>> list)
(package private) void
errorAll(java.lang.Throwable e)
Notify everyone and cleanup.(package private) void
errorMain(java.lang.Throwable e)
Notify only the main subscriber and cleanup.void
init()
boolean
isUnsubscribed()
Indicates whether thisSubscription
is currently unsubscribed.void
unsubscribe()
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.
-
-
-
Field Detail
-
cancel
final RefCountSubscription cancel
-
subscriber
final Subscriber<? super R> subscriber
-
group
final CompositeSubscription group
-
guard
final java.lang.Object guard
-
leftIds
int leftIds
Guarded by guard.
-
rightIds
int rightIds
Guarded by guard.
-
rightMap
final java.util.Map<java.lang.Integer,T2> rightMap
Guarded by guard.
-
leftDone
boolean leftDone
Guarded by guard.
-
rightDone
boolean rightDone
Guarded by guard.
-
-
Constructor Detail
-
ResultManager
public ResultManager(Subscriber<? super R> subscriber)
-
-
Method Detail
-
init
public void init()
-
unsubscribe
public void unsubscribe()
Description copied from interface:Subscription
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.This allows unregistering an
Subscriber
before it has finished receiving all events (i.e. before onCompleted is called).- Specified by:
unsubscribe
in interfaceSubscription
-
isUnsubscribed
public boolean isUnsubscribed()
Description copied from interface:Subscription
Indicates whether thisSubscription
is currently unsubscribed.- Specified by:
isUnsubscribed
in interfaceSubscription
- Returns:
true
if thisSubscription
is currently unsubscribed,false
otherwise
-
errorAll
void errorAll(java.lang.Throwable e)
Notify everyone and cleanup.- Parameters:
e
- the exception
-
errorMain
void errorMain(java.lang.Throwable e)
Notify only the main subscriber and cleanup.- Parameters:
e
- the exception
-
-