Class OnSubscribeGroupJoin.ResultManager

    • Field Detail

      • guard

        final java.lang.Object guard
      • leftIds

        int leftIds
        Guarded by guard.
      • rightIds

        int rightIds
        Guarded by guard.
      • leftMap

        final java.util.Map<java.lang.Integer,​Observer<T2>> leftMap
        Guarded by guard.
      • rightMap

        final java.util.Map<java.lang.Integer,​T2> rightMap
        Guarded by guard.
      • leftDone

        boolean leftDone
        Guarded by guard.
      • rightDone

        boolean rightDone
        Guarded by guard.
    • Constructor Detail

      • ResultManager

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

      • 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​(java.lang.Throwable e)
        Notify everyone and cleanup.
        Parameters:
        e - the exception
      • errorMain

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

        void complete​(java.util.List<Observer<T2>> list)