How to call async functions in Stream.periodic

Question

Is it possible to call an async function inside dart:Stream.periodic function?

I tried to wrap my async function but it is not working, please see code below.

Stream.periodic(Duration(seconds: _pollingInterval), _checkConnectivity)

String _checkConnectivity(int x) async {

return await _connectionRepository.checkConnection();

}

Answer 1

Use asyncMap:

  Stream<String> checkConnectionStream() async* {
    yield* Stream.periodic(Duration(seconds: _pollingInterval), (_) {
      return _connectionRepository.checkConnection();
    }).asyncMap((event) async => await event);
  }