StreamToolsExt<T> extension

on

• Stream<T>

Methods

onData(void onData(T event)) → Stream<T>

Available on Stream<T>, provided by the StreamToolsExt extension

每次触发数据时

repeatLatest({Duration? repeatTimeout, T? onTimeout, T onRepeatTimeout()?, bool repeatError = false, bool? broadcast}) → Stream<T>

Available on Stream<T>, provided by the StreamToolsExt extension

重复上一个，对源stream会一直保持订阅，永远不会取消，建议前向使用bindCancellable或者bindLifecycle，来自动解除订阅