sendMessagesExpectReply method

Future<List<ButtplugServerMessage>> sendMessagesExpectReply(
  1. List<ButtplugClientMessage> messages
)

Implementation

Future<List<ButtplugServerMessage>> sendMessagesExpectReply(List<ButtplugClientMessage> messages) async {
  if (!_connected) {
    throw ButtplugClientException("Cannot send message while disconnected");
  }
  final replies = <Future<ButtplugServerMessage>>[];
  for (final message in messages) {
    _sorter.prepareMessage(message);
    replies.add(_sorter.waitForMessage(message.id));
  }
  final result = Future.wait(replies);
  try {
    for (final message in messages) {
      _connector.send([message.asClientMessageUnion()]);
    }
  } catch (error, stackTrace) {
    _markDisconnected(error, stackTrace);
  }
  return result;
}