saveThreadMessage method

@override Future<void> saveThreadMessage(String threadId, Map<String, dynamic> message)

Implementation

@override
Future<void> saveThreadMessage(
  String threadId,
  Map<String, dynamic> message,
) async {
  if (!DB.isConnected) {
    _warnWithoutError();
    await fallback.saveThreadMessage(threadId, message);
    return;
  }
  try {
    await primary.saveThreadMessage(threadId, message);
  } catch (error) {
    _warn(error);
    await fallback.saveThreadMessage(threadId, message);
  }
}