waitForSync method

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

Awaits until all registered streams are synchronised.

Implementation

Future<void> waitForSync({
  Duration timeout = const Duration(seconds: 5),
}) async {
  final deadline = DateTime.now().add(timeout);

  while (DateTime.now().isBefore(deadline)) {
    if (_allSynced()) return;
    await Future<void>.delayed(Duration(milliseconds: tickIntervalMs));
  }

  _logger.warning('Sync timeout after ${timeout.inMilliseconds}ms');
}