Package rx

Interface AsyncEmitter<T>

    • Method Detail

      • setSubscription

        void setSubscription​(Subscription s)
        Sets a Subscription on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
        Parameters:
        s - the subscription, null is allowed
      • setCancellation

        void setCancellation​(AsyncEmitter.Cancellable c)
        Sets a Cancellable on this emitter; any previous Subscription or Cancellation will be unsubscribed/cancelled.
        Parameters:
        c - the cancellable resource, null is allowed
      • requested

        long requested()
        The current outstanding request amount.

        This method it threadsafe.

        Returns:
        the current outstanding request amount