publish method

  1. @override
Future<void> publish(
  1. String topic,
  2. String message,
  3. int ttl, {
  4. bool? prompt,
  5. int? tag,
})
override

Implementation

@override
Future<void> publish(
  String topic,
  String message,
  int ttl, {
  bool? prompt,
  int? tag,
}) async {
  _checkInitialized();

  Map<String, dynamic> data = {
    'message': message,
    'ttl': ttl,
    'topic': topic,
  };

  if (prompt != null) data['prompt'] = prompt;
  if (tag != null) data['tag'] = tag;

  try {
    // print('publishing');
    var value = await jsonRPC.sendRequest(
      _buildMethod(JSON_RPC_PUBLISH),
      data,
    );
    // print(value);
    await messageTracker!.recordMessageEvent(topic, message);
  } catch (e) {
    // print(e);
    onRelayClientError.broadcast(ErrorEvent(e));
  }
}