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