Interface SubscriptionWithCursor<T>

    • Method Detail

      • active

        boolean active()
      • active_$eq

        void active_$eq​(boolean x$1)
      • dispatch

        void dispatch​(T element)
      • subscriber

        org.reactivestreams.Subscriber<? super T> subscriber()
      • totalDemand

        long totalDemand()
        Do not increment directly, use `moreRequested(Long)` instead (it provides overflow protection)!
      • totalDemand_$eq

        void totalDemand_$eq​(long x$1)