subscribe method

Stream<NatsMessage> subscribe(String subscriberId, String subject, { String? queueGroup, })

Subscribes to the subject with a given subscriberId and an optional queueGroup set to group the responses

var client = NatsClient("localhost", 4222);
await client.connect();
var messageStream = client.subscribe("sub-1", "foo-topic"); // No [queueGroup] set
var messageStream = client.subscribe("sub-1", "foo-topic", queueGroup: "group-1")

messageStream.listen((message) {
  // Do something awesome
});

Implementation

Stream<NatsMessage> subscribe(
  String subscriberId,
  String subject, {
  String? queueGroup,
}) =>
    _doSubscribe(false, subscriberId, subject);