subscribe method

  1. @override
Future<WsSubscribeResult> subscribe(
  1. List<String> topics, {
  2. int? sinceSeq,
  3. double? positionHz,
})
override

Subscribes to topic filters (MQTT wildcards), optionally resuming after sinceSeq.

Implementation

@override
Future<WsSubscribeResult> subscribe(
  List<String> topics, {
  int? sinceSeq,
  double? positionHz,
}) async {
  final r = await _emit('subscribe', {
    'topics': topics,
    'sinceSeq': ?sinceSeq,
    if (positionHz != null) 'options': {'positionHz': positionHz},
  }, null);
  return r is Map
      ? WsSubscribeResult.fromJson(r.cast<String, Object?>())
      : WsSubscribeResult(topics: topics);
}