connect method

Future<void> connect()

Implementation

Future<void> connect() async {
  if (_socket != null) return;
  final socket = await WebSocket.connect(_uri);
  _socket = socket;

  socket.listen(
    _handleMessage,
    onDone: () => _cleanup(),
    onError: (_) => _cleanup(),
    cancelOnError: true,
  );

  _heartbeat = Timer.periodic(
    const Duration(seconds: 20),
    (_) => _send(NeuronDebugProtocol.heartbeat()),
  );
}