onAck method

Future<void> onAck(
  1. RelayAckMessage message
)

Handles the ack of a push: drops the acknowledged blobs and flushes what queued up in the meantime.

Implementation

Future<void> onAck(RelayAckMessage message) async {
  _seqTracker.addRange(from: message.seq - message.count, to: message.seq);
  _queue.ack(message.count);

  await flush();

  if (message.compact) {
    await uploadSnapshot(message.seq);
  }
}