Interface SubscriberManagement<T>

    • Method Detail

      • initialBufferSize

        int initialBufferSize()
      • maxBufferSize

        int maxBufferSize()
      • requestFromUpstream

        void requestFromUpstream​(long elements)
        called when we are ready to consume more elements from our upstream MUST NOT call pushToDownstream
      • cancelUpstream

        void cancelUpstream()
        called before shutdown() if the stream is *not* being regularly completed but shut-down due to the last subscriber having canceled its subscription
      • shutdown

        void shutdown​(boolean completed)
        called when the spi.Publisher/Processor is ready to be shut down
      • createSubscription

        SubscriptionWithCursor createSubscription​(org.reactivestreams.Subscriber<? super T> subscriber)
        Use to register a subscriber
      • bufferDebug

        java.lang.String bufferDebug()
      • pendingFromUpstream_$eq

        void pendingFromUpstream_$eq​(long x$1)
      • moreRequested

        void moreRequested​(SubscriptionWithCursor subscription,
                           long elements)
        more demand was signaled from a given subscriber
      • requestFromUpstreamIfRequired

        void requestFromUpstreamIfRequired()
      • pushToDownstream

        void pushToDownstream​(T value)
        this method must be called by the implementing class whenever a new value is available to be pushed downstream
      • completeDownstream

        void completeDownstream()
        this method must be called by the implementing class whenever it has been determined that no more elements will be produced
      • abortDownstream

        void abortDownstream​(java.lang.Throwable cause)
        this method must be called by the implementing class to push an error downstream
      • registerSubscriber

        void registerSubscriber​(org.reactivestreams.Subscriber<? super T> subscriber)
        Register a new subscriber.
      • addSubscription

        void addSubscription​(org.reactivestreams.Subscriber<? super T> subscriber)
      • unregisterSubscription

        void unregisterSubscription​(SubscriptionWithCursor subscription)
        called from Subscription::cancel, i.e. from another thread, override to add synchronization with itself, subscribe and moreRequested
      • unregisterSubscriptionInternal

        void unregisterSubscriptionInternal​(SubscriptionWithCursor subscription)