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 java.lang.Object

Manage the left and right sources.

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) CompositeSubscription	group
(package private) java.lang.Object	guard
(package private) boolean	leftDone	Guarded by guard.
(package private) int	leftId	Guarded by guard.
(package private) java.util.Map<java.lang.Integer,TLeft>	leftMap	Guarded by guard.
(package private) boolean	rightDone	Guarded by guard.
(package private) int	rightId	Guarded by guard.
(package private) java.util.Map<java.lang.Integer,TRight>	rightMap	Guarded by guard.
(package private) 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 Detail

group

final CompositeSubscription group

subscriber

final Subscriber<? super R> subscriber

guard

final java.lang.Object guard

leftDone

boolean leftDone

Guarded by guard.

leftId

int leftId

Guarded by guard.

leftMap

final java.util.Map<java.lang.Integer,TLeft> leftMap

Guarded by guard.

rightDone

boolean rightDone

Guarded by guard.

rightId

int rightId

Guarded by guard.

rightMap

final java.util.Map<java.lang.Integer,TRight> rightMap

Guarded by guard.

Constructor Detail

ResultSink

public ResultSink(Subscriber<? super R> subscriber)

Method Detail

run

public void run()