start method

@override Future<void> start()

Implementation

@override
Future<void> start() async {
  try {
    /// 'wss://$_host:$_port/ws/',
    socket = SocketBase.fromWebSocket(
      [
        if (_wss) 'wss://' else 'ws://',
        _host,
        ':',
        _port.toString(),
        _path,
      ].join(''),
      callback: (msg) {
        // final messageJson = json.decode(msg);
        final msgJS = MessageTypeJS(false, msg);
        final message = MessageType(inApp: false, message: msg);
        log('flutter log: ${msgJS.message}');
        _sendNotification(msgJS, _replace, _reload);
        _messageController.add(message);
      },
    );
    socket.connect();
  } catch (e) {
    log('initial websocket error $e');
  }
}