Package io.gravitee.gateway.reactive.api.context.kafka

Interface NetworkController

public interface NetworkController

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    pause(Duration duration)
    Pauses the acceptance of incoming data for the specified duration.
    void
    resume()
    Immediately resume the flow of incoming data.

  • Method Details

    • pause

      void pause(Duration duration)
      Pauses the acceptance of incoming data for the specified duration. The flow is resumed once the duration is over or an explicit call to resume() is performed.
      Parameters:
      duration - the duration to apply before calling resume.

    • resume

      void resume()
      Immediately resume the flow of incoming data.