talk method

Future<void> talk(
  1. String subject,
  2. Object? data, {
  3. Future onAck(
    1. AckableClient,
    2. AckedMessage
    )?,
  4. Map<String, Object>? headers,
})

Implementation

Future<void> talk(String subject,
    Object? data, {
      Future Function(AckableClient, AckedMessage)? onAck,
      Map<String, Object>? headers }) {
  final ret = _clients.map((cli) => cli.talk(subject, data, (ack) async {
    if (onAck != null) {
      return onAck(cli, ack);
    }
  }, headers: headers));

  return Future.wait(ret);
}