connect method

@override Future<void> connect()

Implementation

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