connect method

@override Future<void> connect()

Implementation

@override
Future<void> connect() async {
  _wsChannel = WebSocketChannel.connect(Uri.parse('ws://127.0.0.1:12345'));
  await _wsChannel?.ready;
  _wsChannel!.stream.forEach((element) async {
    try {
      logInfo(element);
      List<dynamic> msgs = jsonDecode(element);
      for (var msg in msgs) {
        _serverMessageStream.add(ButtplugServerMessage.fromJson(msg));
      }
    } catch (e, s) {
      logError("Error adding message to stream: $e");
      logError(s);
      await disconnect();
    }
  });
}