ack method

void ack()

Signals that message has been processed and we are ready for the next one. This method will not trigger offset commit if this envelope has been created by a high-level Consumer.

Implementation

void ack() {
  _completer.complete(new _ProcessingResult.ack());
}