waitForPendingCacheWrites static method

Future<void> waitForPendingCacheWrites({
  1. Duration timeout = const Duration(seconds: 5),
})

Implementation

static Future<void> waitForPendingCacheWrites({Duration timeout = const Duration(seconds: 5)}) async {
  if (_pendingCacheWrites.isEmpty) return;

  try {
    await Future.wait(_pendingCacheWrites).timeout(timeout);
  } catch (e) {
    // Ignore timeouts in tests
  } finally {
    _pendingCacheWrites.clear();
  }
}