connect method

@override Future<void> connect(String host, int port, { dynamic args, })

Establishes a connection to the AMI server.

host - Server hostname or IP address port - Server port number args - Optional connection-specific arguments

Implementation

@override
Future<void> connect(String host, int port, {dynamic args}) async {
  final useSSL = args == true;
  _socket = WebSocketChannel.connect(
    Uri(host: host, port: port, scheme: useSSL ? 'wss' : 'ws'),
  );
  _listener = _socket!.stream.listen(
    handleMessage,
    onError: (e) {
      _controller!.addError(e);
      disconnect();
    },
    cancelOnError: true,
  );
  _controller!.add(true);
}