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 Object
implements Subscription

Manages sub-observers and subscriptions.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftDurationObserver	Observe left duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.LeftObserver	Observe the left source.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightDurationObserver	Observe right duration and apply termination.
(package private) final class	OnSubscribeGroupJoin.ResultManager.RightObserver	Observe the right source.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final RefCountSubscription	cancel
(package private) final CompositeSubscription	group
(package private) final Object	guard
(package private) boolean	leftDone	Guarded by guard.
(package private) int	leftIds	Guarded by guard.
(package private) final Map<Integer,Observer<T2>>	leftMap	Guarded by guard.
(package private) boolean	rightDone	Guarded by guard.
(package private) int	rightIds	Guarded by guard.
(package private) final Map<Integer,T2>	rightMap	Guarded by guard.
(package private) final 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(List<Observer<T2>> list)
(package private) void	errorAll(Throwable e)	Notify everyone and cleanup.
(package private) void	errorMain(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 Details

cancel

final RefCountSubscription cancel

subscriber

final Subscriber<? super R> subscriber

group

final CompositeSubscription group

guard

final Object guard

leftIds

int leftIds

Guarded by guard.

rightIds

int rightIds

Guarded by guard.

leftMap

final Map<Integer,Observer<T2>> leftMap

Guarded by guard.

rightMap

final Map<Integer,T2> rightMap

Guarded by guard.

leftDone

boolean leftDone

Guarded by guard.

rightDone

boolean rightDone

Guarded by guard.

Constructor Details

ResultManager

public ResultManager(Subscriber<? super R> subscriber)

Method Details

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(Throwable e)

Notify everyone and cleanup.

Parameters:

e - the exception

errorMain

void errorMain(Throwable e)

Notify only the main subscriber and cleanup.

Parameters:

e - the exception

complete

void complete(List<Observer<T2>> list)