Class OnSubscribeGroupJoin.ResultManager.RightDurationObserver

java.lang.Object
rx.Subscriber<D2>
rx.internal.operators.OnSubscribeGroupJoin.ResultManager.RightDurationObserver
All Implemented Interfaces:
Observer<D2>, Subscription
Enclosing class:
OnSubscribeGroupJoin.ResultManager

final class OnSubscribeGroupJoin.ResultManager.RightDurationObserver extends Subscriber<D2>
Observe right duration and apply termination.
  • Field Details

    • id

      final int id
    • once

      boolean once
  • Constructor Details

    • RightDurationObserver

      public RightDurationObserver(int id)
  • Method Details