aeron-driver/src/main/java/io/aeron/driver/RetransmitHandler.java
public void onRetransmitReceived(final int termId, final int termOffset)
    {
        final RetransmitAction action = activeRetransmitsMap.get(termId, termOffset);

        if (null != action && DELAYED == action.state)
        {
            activeRetransmitsMap.remove(termId, termOffset);
            action.cancel();
            // do not go into linger
        }
    }
public void onRetransmitReceived(final int termId, final int termOffset)
    {
        final RetransmitAction action = activeRetransmitsMap.get(termId, termOffset);

        if (null != action && DELAYED == action.state)
        {
            activeRetransmitsMap.remove(termId, termOffset);
            action.cancel();
            // do not go into linger
        }
    }
public void onRetransmitReceived ( final int termId , final int termOffset ) { final RetransmitAction action = activeRetransmitsMap . get ( termId , termOffset ) ; if ( null != action && DELAYED == action . state ) { activeRetransmitsMap . remove ( termId , termOffset ) ; action . cancel ( ) ; // do not go into linger } }
Called to indicate a retransmission is received that may obviate the need to send one ourselves.
<p>
NOTE: Currently only called from unit tests. Would be used for retransmitting from receivers for NAK suppression.

@param termId     of the data
@param termOffset of the data
Called to indicate a retransmission is received that may obviate the need to send one ourselves . <p > NOTE : Currently only called from unit tests . Would be used for retransmitting from receivers for NAK suppression .