subscribe method

  1. @override
void subscribe(
  1. String destination,
  2. dynamic onData(
    1. String json
    ), {
  3. dynamic onDone()?,
  4. dynamic onError(
    1. Object error
    )?,
})
override

Implementation

@override
void subscribe(String destination, Function(String json) onData,
    {Function()? onDone, Function(Object error)? onError}) {
  Uri uri = Uri(scheme: 'ws', host: hostName, port: port, path: endpoint);
  log('Creating WebSocket connection to ${uri.toString()}',
      logLevel: TOAST_MESSAGE);
  channel = WebSocketChannel.connect(uri); //'ws://localhost:8080/socket'
  if (channel != null) {
    channel?.stream.listen((message) {
      onData(message);
    }, onDone: onDone, onError: onError);
  }
}