Class OperatorTakeUntilPredicate.ParentSubscriber

java.lang.Object
rx.Subscriber<T>
rx.internal.operators.OperatorTakeUntilPredicate.ParentSubscriber
All Implemented Interfaces:
Observer<T>, Subscription
Enclosing class:
OperatorTakeUntilPredicate<T>

final class OperatorTakeUntilPredicate.ParentSubscriber extends Subscriber<T>
Subscriber returned to the upstream.
  • Field Details

    • child

      private final Subscriber<? super T> child
    • done

      private boolean done
  • Constructor Details

    • ParentSubscriber

      ParentSubscriber(Subscriber<? super T> child)
  • Method Details