acknowledge method

void acknowledge(
  1. Subscription subscription,
  2. DataMessage dataMessage
)

Implementation

void acknowledge(Subscription subscription, DataMessage dataMessage) {
  Ack ack = Ack()
    ..subject = dataMessage.subject
    ..sequence = dataMessage.sequence;
  _natsClient.pub(subscription.ackInbox, ack.writeToBuffer());
}