如何在每一秒钟返回布尔的颤音中创建流

Question

我正在制作一个应用程序。我想检查我的服务器状态，并提供用户信息 关于服务器。我该怎么做。流对此有好处。有些人可以为我提供代码。

Answer 1

使用AsyncMap

Stream<String> checkConnectionStream() async* {
  yield* Stream.periodic(Duration(seconds: 1), (_) {
    return //your function
  }).asyncMap((event) async => await event);
}

Answer 2

只需遵循本指南
假设您的bool返回值函数是

Future<bool> isGpsOn() async {
  return await Geolocator().isLocationServiceEnabled();
}

，这是从bool值创建流

Stream futureToStream(fn, defaultValue, Duration duration) async* {
  var result;
  while (true) {
    try {
      result = await fn();
    }
    catch (error) {
      result = defaultValue;
    }
    finally {
      yield result;
    }
    await Future.delayed(duration);
  }
}
final gpsStatusStream = futureToStream(isGpsOn, false, Duration(seconds: 5));
gpsStatusStream.listen((enabled) {
  print(enabled ? 'enabled' : 'disabled');
});