Package rx.internal.operators
Class OnSubscribeGroupJoin.ResultManager
java.lang.Object
rx.internal.operators.OnSubscribeGroupJoin.ResultManager
- All Implemented Interfaces:
Subscription
Manages sub-observers and subscriptions.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
Observe left duration and apply termination.(package private) final class
Observe the left source.(package private) final class
Observe right duration and apply termination.(package private) final class
Observe the right source. -
Field Summary
FieldsModifier and TypeFieldDescription(package private) final RefCountSubscription
(package private) final CompositeSubscription
(package private) final Object
(package private) boolean
Guarded by guard.(package private) int
Guarded by guard.Guarded by guard.(package private) boolean
Guarded by guard.(package private) int
Guarded by guard.Guarded by guard.(package private) final Subscriber
<? super R> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
Notify everyone and cleanup.(package private) void
Notify only the main subscriber and cleanup.void
init()
boolean
Indicates whether thisSubscription
is currently unsubscribed.void
Stops the receipt of notifications on theSubscriber
that was registered when this Subscription was received.
-
Field Details
-
cancel
-
subscriber
-
group
-
guard
-
leftIds
int leftIdsGuarded by guard. -
rightIds
int rightIdsGuarded by guard. -
leftMap
Guarded by guard. -
rightMap
Guarded by guard. -
leftDone
boolean leftDoneGuarded by guard. -
rightDone
boolean rightDoneGuarded by guard.
-
-
Constructor Details
-
ResultManager
-
-
Method Details
-
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
Notify everyone and cleanup.- Parameters:
e
- the exception
-
errorMain
Notify only the main subscriber and cleanup.- Parameters:
e
- the exception
-
complete
-