Package rx.internal.operators

Class OnSubscribeGroupJoin.ResultManager

java.lang.Object

rx.internal.operators.OnSubscribeGroupJoin.ResultManager

All Implemented Interfaces:

Subscription

Enclosing class:

OnSubscribeGroupJoin<T1,T2,D1,D2,R>

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

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 this Subscription is currently unsubscribed.
void	unsubscribe()	Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.

leftMap

final java.util.Map<java.lang.Integer,Observer<T2>> leftMap

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 the Subscriber 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 interface Subscription

isUnsubscribed

public boolean isUnsubscribed()

Description copied from interface: Subscription

Indicates whether this Subscription is currently unsubscribed.

Specified by:

isUnsubscribed in interface Subscription

Returns:

true if this Subscription 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

complete

void complete(java.util.List<Observer<T2>> list)