Interface RequestStrategy

    • Method Detail

      • requestDemand

        int requestDemand​(int remainingRequested)
        Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.

        remainingRequested - current remaining number of elements that have been requested from upstream but not received yet
        demand of more elements from the stream, returning 0 means that no more elements will be requested for now