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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
run()
-
-
-
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)
-
-