Package rx.internal.operators

Class OnSubscribeJoin.ResultSink

java.lang.Object

rx.internal.operators.OnSubscribeJoin.ResultSink

Enclosing class:

OnSubscribeJoin<TLeft,TRight,TLeftDuration,TRightDuration,R>

final class OnSubscribeJoin.ResultSink
extends Object

Manage the left and right sources.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	OnSubscribeJoin.ResultSink.LeftSubscriber	Observes the left values.
(package private) final class	OnSubscribeJoin.ResultSink.RightSubscriber	Observes the right values.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final CompositeSubscription	group
(package private) final Object	guard
(package private) boolean	leftDone	Guarded by guard.
(package private) int	leftId	Guarded by guard.
(package private) final Map<Integer,TLeft>	leftMap	Guarded by guard.
(package private) boolean	rightDone	Guarded by guard.
(package private) int	rightId	Guarded by guard.
(package private) final Map<Integer,TRight>	rightMap	Guarded by guard.
(package private) final Subscriber<? super R>	subscriber

Constructor Summary

Constructors

Constructor	Description
ResultSink(Subscriber<? super R> subscriber)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class java.lang.Object

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

Field Details

group

final CompositeSubscription group

subscriber

final Subscriber<? super R> subscriber

guard

final Object guard

leftDone

boolean leftDone

Guarded by guard.

leftId

int leftId

Guarded by guard.

leftMap

final Map<Integer,TLeft> leftMap

Guarded by guard.

rightDone

boolean rightDone

Guarded by guard.

rightId

int rightId

Guarded by guard.

rightMap

final Map<Integer,TRight> rightMap

Guarded by guard.

Constructor Details

ResultSink

public ResultSink(Subscriber<? super R> subscriber)

Method Details

run

public void run()