Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.connector

Interface FlowControl

  • All Known Implementing Classes:
    FlowControlledReplyChannelWriter, NoopFlowControl
    public interface FlowControl
    Controls the flow of the messages via communication channel. Implementations should send messages only when requested. Once the cancellation is invoked, implementations should stop sending messages.
    Since:
    4.6.0
    Author:
    Milan Savic, Stefan Dragisic, Allard Buijze

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void cancel()
      Cancels response sending.
      void request​(long requested)
      Requests the requested amount of responses to be sent.

    • Method Detail

      • request

        void request​(long requested)
        Requests the requested amount of responses to be sent.
        Parameters:
        requested - number of responses to be sent

      • cancel

        void cancel()
        Cancels response sending.