如何获得间隔不均匀的飞镖流？

Question

我是 dart 和 Flutter 的新手，很想就我面临的算法问题获得一些建议。

我想将我的 Flutter 应用程序连接到蓝牙设备（该部分已完成，我已经连接）并以不均匀的间隔发送消息。我有一个列表中的消息，对于每个消息，我都知道我想在什么时间（毫秒）发送消息。

所以假设下面的消息是一字排开的：

• start 0 毫秒
• init_app 100 毫秒
• user_pick_x 500 毫秒
• user_start_x 500ms （将在user_pick_x 之后发送，应保证订单）
• interrupt 3500 毫秒

我找到了创建流的文档，但它总是谈论单个间隔值。 https://dart.dev/articles/libraries/creating-streams.

想法：

• 从技术上讲，我可以传入Duration 对象列表，并使用自定义生成器async* 以及消息字符串。
• 或者，我可以将时间间隔设置为最低时间增量，并检查每个时间间隔是否应发送消息。在示例的情况下，每 100 毫秒。

如果能够暂停/取消流也很好。这是流本身可以做的事情。

Answer 1

我认为最简单的方法是在指定的时间间隔发出这些消息。比如：

Future<void> _wait(int milliseconds) async =>
  await Future<void>.delayed(Duration(milliseconds: milliseconds));

Stream<String> generateMessages() async* {
  yield 'start';
  await _wait(100);
  yield 'init_all';
  await _wait(400);
  yield 'user_pick_x';
  yield 'user_start_x';
  await _wait(3000);
  yield 'interrupt';
}

void main() {
  generateMessages().listen((msg) {
    print('${DateTime.now()}: $msg');
  });
}

将打印：

2021-07-25 10:21:21.429: start
2021-07-25 10:21:21.531: init_all
2021-07-25 10:21:21.934: user_pick_x
2021-07-25 10:21:21.934: user_start_x
2021-07-25 10:21:24.938: interrupt

如果您想确保流的侦听器异步接收事件 - 因此不干扰等待毫秒，您可以显式使用默认情况下异步调用侦听器的 StreamController（确保导入 dart:async --- dart:io 仅用于sleep 的示例中，以表明即使在阻塞操作中它也会与等待并行运行）：

import 'dart:async';
import 'dart:io';

Future<void> _wait(int milliseconds) async {
  print('WAIT $milliseconds ms');
  await Future<void>.delayed(Duration(milliseconds: milliseconds));
}

Stream<String> generateMessages() {
  final controller = StreamController<String>(sync: false);
  controller.onListen = () async {
    controller.add('start');
    await _wait(100);
    controller.add('init_all');
    await _wait(400);
    controller.add('user_pick_x');
    controller.add('user_start_x');
    await _wait(3000);
    controller.add('interrupt');
  };
  return controller.stream;
}

void main() {
  generateMessages().listen((msg) {
    sleep(const Duration(milliseconds: 120));
    print('${DateTime.now()}: $msg');
  });
}