Package rx.internal.operators
Class OnSubscribeJoin.ResultSink
java.lang.Object
rx.internal.operators.OnSubscribeJoin.ResultSink
- Enclosing class:
OnSubscribeJoin<TLeft,
TRight, TLeftDuration, TRightDuration, R>
Manage the left and right sources.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
Observes the left values.(package private) final class
Observes the right values. -
Field Summary
FieldsModifier and TypeFieldDescription(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
-
Field Details
-
group
-
subscriber
-
guard
-
leftDone
boolean leftDoneGuarded by guard. -
leftId
int leftIdGuarded by guard. -
leftMap
Guarded by guard. -
rightDone
boolean rightDoneGuarded by guard. -
rightId
int rightIdGuarded by guard. -
rightMap
Guarded by guard.
-
-
Constructor Details
-
ResultSink
-
-
Method Details
-
run
public void run()
-