Class OnSubscribeGroupJoin.ResultManager.LeftDurationObserver

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

final class OnSubscribeGroupJoin.ResultManager.LeftDurationObserver extends Subscriber<D1>
Observe left duration and apply termination.
  • Field Details

    • id

      final int id
    • once

      boolean once
  • Constructor Details

    • LeftDurationObserver

      public LeftDurationObserver(int id)
  • Method Details