我正在迁移到Bloc 8.0.0
进行状态管理。StreamSubscription
我遇到了一个问题,Stream 的Emitter没有提供Future
. 我知道,我可以用它listen
来获取订阅,但我想保持一致性并在任何地方使用 bloc 方式。
forEach
是否可以在使用或onEach
从时获得流订阅Emitter
?就我而言,我想暂停一个流一段时间然后恢复它,但似乎没有任何方法可以从emit.forEach<T>{}
.
例子:
await emit.forEach<Model>(
myStream,
onData: (data) => state.copyWith(someData: data.someData),
);
在此示例中,无法获取StreamSubscription
. 流自动关闭。我想在这里获得一个订阅对象,这样我就可以暂停流。
也许我错过了一些文档或示例。任何建议都会有很大帮助。