如何在 Stream.periodic 中调用异步函数

Question

是否可以在 dart:Stream.periodic 函数中调用异步函数？

我试图包装我的异步函数，但它不起作用，请参阅下面的代码。

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

String _checkConnectivity(int x) async {

return await _connectionRepository.checkConnection();

}

Answer 1

使用异步映射：

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