prepareMessage method

void prepareMessage(
  1. ButtplugMessage outgoing
)

Implementation

void prepareMessage(ButtplugMessage outgoing) {
  outgoing.id = messageCounter;
  StreamController<ButtplugServerMessage> responseStream = StreamController();
  var responseCompleter = Completer<ButtplugServerMessage>();
  responseStream.stream.listen((ButtplugServerMessage msg) {
    responseCompleter.complete(msg);
  });
  waitingFutures[messageCounter] = MessageCompletionFuture(responseStream.sink, Future(() async {
    return await responseCompleter.future;
  }));
  messageCounter += 1;
}