connect method

Future<void> connect(
  1. ButtplugClientConnector connector
)

Implementation

Future<void> connect(ButtplugClientConnector connector) async {
  _connector = connector;
  _connector!.messageStream.listen((message) {
    if (message.id != 0) {
      _sorter.checkMessage(message);
      return;
    }
    if (message.deviceAdded != null) {
      var device = ButtplugClientDevice(message.deviceAdded!, (msg) => _sendMessageExpectReply(msg));
      _devices[device.index] = device;
      _eventStream.add(DeviceAddedEvent(device));
    }
    if (message.deviceRemoved != null) {
      var device = _devices[message.deviceRemoved!.deviceIndex]!;
      _devices.remove(message.deviceRemoved!.deviceIndex);
      _eventStream.add(DeviceRemovedEvent(device));
    }
  });
  await _connector!.connect();
  await _runHandshake();
}