在颤动中取消 StreamSubscription

Question

我有以下流订阅

Stream<Uint8List> stream = await USBSerialSingleton.instance.inputStream;
usbStream = stream.listen(onDataReceivedFromUSBSerial);

inputStream 是这样暴露的广播流。

Future<Stream<Uint8List>> get inputStream async {
final UsbPort port = await this.port;
return port.inputStream.asBroadcastStream();
}

我想停止收听直播，所以我打电话给

usbStream.cancel();

但我一直在我的 onDataReceivedFromUSBSerial 方法上收到消息。即使我关闭了所有这些都在其上实现的对话，我仍然会在onDataReceivedFromUSBSerial 上收到消息。

问题：如何停止收听我的usbStream？

Answer 1

您必须等待订阅取消，所以这样做：

await usbStream.cancel();