Class OnSubscribeGroupJoin.ResultManager

java.lang.Object
rx.internal.operators.OnSubscribeGroupJoin.ResultManager
All Implemented Interfaces:
Subscription
Enclosing class:
OnSubscribeGroupJoin<T1,T2,D1,D2,R>

final class OnSubscribeGroupJoin.ResultManager extends Object implements Subscription
Manages sub-observers and subscriptions.
  • Field Details

    • cancel

      final RefCountSubscription cancel
    • subscriber

      final Subscriber<? super R> subscriber
    • group

      final CompositeSubscription group
    • guard

      final Object guard
    • leftIds

      int leftIds
      Guarded by guard.
    • rightIds

      int rightIds
      Guarded by guard.
    • leftMap

      final Map<Integer,Observer<T2>> leftMap
      Guarded by guard.
    • rightMap

      final Map<Integer,T2> rightMap
      Guarded by guard.
    • leftDone

      boolean leftDone
      Guarded by guard.
    • rightDone

      boolean rightDone
      Guarded by guard.
  • Constructor Details

    • ResultManager

      public ResultManager(Subscriber<? super R> subscriber)
  • Method Details

    • init

      public void init()
    • unsubscribe

      public void unsubscribe()
      Description copied from interface: Subscription
      Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

      This allows unregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

      Specified by:
      unsubscribe in interface Subscription
    • isUnsubscribed

      public boolean isUnsubscribed()
      Description copied from interface: Subscription
      Indicates whether this Subscription is currently unsubscribed.
      Specified by:
      isUnsubscribed in interface Subscription
      Returns:
      true if this Subscription is currently unsubscribed, false otherwise
    • errorAll

      void errorAll(Throwable e)
      Notify everyone and cleanup.
      Parameters:
      e - the exception
    • errorMain

      void errorMain(Throwable e)
      Notify only the main subscriber and cleanup.
      Parameters:
      e - the exception
    • complete

      void complete(List<Observer<T2>> list)