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.
  • 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()