Class AckStateMachine

java.lang.Object
com.quietterminal.neon.core.AckStateMachine
public final class AckStateMachine extends Object

  • Constructor Details

    • AckStateMachine

      public AckStateMachine(long ackTimeoutMs, int maxAckRetries)

  • Method Details

    • track

      public void track(short sequence, NeonPacket packet)

    • process

      public AckStateMachine.ProcessResult process()

    • markResent

      public NeonPacket markResent(short sequence)

    • acknowledge

      public void acknowledge(short sequence)

    • getPacket

      public NeonPacket getPacket(short sequence)

    • hasPending

      public boolean hasPending()