Package org.reactivestreams

Class FlowAdapters.ReactiveToFlowSubscription

  • All Implemented Interfaces:
    Subscription
    Enclosing class:
    FlowAdapters
    static final class FlowAdapters.ReactiveToFlowSubscription
extends java.lang.Object
implements Subscription
    Wraps a Flow Subscription and converts the calls to a Reactive Streams Subscription.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) java.util.concurrent.Flow.Subscription flow  

    • Constructor Summary

      Constructors 
      Constructor Description
      ReactiveToFlowSubscription​(java.util.concurrent.Flow.Subscription flow)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void cancel()
      Request the Publisher to stop sending data and clean up resources.
      void request​(long n)
      No events will be sent by a Publisher until demand is signaled via this method.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • flow

        final java.util.concurrent.Flow.Subscription flow

    • Constructor Detail

      • ReactiveToFlowSubscription

        public ReactiveToFlowSubscription​(java.util.concurrent.Flow.Subscription flow)

    • Method Detail

      • request

        public void request​(long n)
        Description copied from interface: Subscription
        No events will be sent by a Publisher until demand is signaled via this method.

        It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

        Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

        A Publisher can send less than is requested if the stream ends but then must emit either Subscriber.onError(Throwable) or Subscriber.onComplete().

        Specified by:
        request in interface Subscription
        Parameters:
        n - the strictly positive number of elements to requests to the upstream Publisher

      • cancel

        public void cancel()
        Description copied from interface: Subscription
        Request the Publisher to stop sending data and clean up resources.

        Data may still be sent to meet previously signalled demand after calling cancel.

        Specified by:
        cancel in interface Subscription