waitForReply method

Future<AmqpMessage> waitForReply(
  1. String correlationId
)

Implementation

Future<AmqpMessage> waitForReply(String correlationId) async {
  final completer = Completer<AmqpMessage>();
  _replyCompleter[correlationId] = completer;
  return await completer.future;
}