StreamExtensions<T> extension

Stream扩展操作符

on

• Stream<T>

Methods

auditTime(Duration duration) → Stream<T>

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

审计时间操作符

bufferCount(int count, [int? startBufferEvery]) → Stream<List<T>>

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

按数量缓冲

bufferTime(Duration duration, {int? maxBufferSize}) → Stream<List<T>>

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

按时间缓冲

bufferWith(Stream<void> bufferStream) → Stream<List<T>>

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

缓冲操作符

combineWith<U, R>(Stream<U> other, R combiner(T, U)) → Stream<R>

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

组合值

concatWith(Stream<T> other) → Stream<T>

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

连接值（concatWith的别名，与concatWithStream保持一致）

concatWithStream(Stream<T> other) → Stream<T>

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

连接多个Stream

debounceTime(Duration duration) → Stream<T>

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

防抖操作符

defaultIfEmpty(T defaultValue) → Stream<T>

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

如果为空则返回默认值

delayTime(Duration duration) → Stream<T>

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

延迟操作符

dematerialize<R>() → Stream<R>

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

将StreamEvent解包为事件

distinctUntilChanged() → Stream<T>

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

去重操作符

distinctUntilChangedBy(bool equals(T, T)) → Stream<T>

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

去重操作符（带自定义比较函数）

endWith(T value) → Stream<T>

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

在流结束时添加值

exhaustMap<R>(Stream<R> mapper(T)) → Stream<R>

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

耗尽映射

flatMapValue<R>(Stream<R> mapper(T)) → Stream<R>

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

异步映射

groupByValue<K>(K keySelector(T)) → Stream<GroupedStream<K, T>>

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

分组操作符

isEmpty() → Future<bool>

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

检查是否为空

isNotEmpty() → Future<bool>

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

检查是否不为空

mapNotNull<R>(R? mapper(T)) → Stream<R>

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

安全映射

materialize() → Stream<StreamEvent<T>>

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

将事件包装为StreamEvent

mergeWith(Stream<T> other) → Stream<T>

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

合并多个Stream

onErrorResumeNext(Stream<T> resumeStream) → Stream<T>

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

错误时切换到另一个流

onErrorReturn(T defaultValue) → Stream<T>

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

错误时返回默认值

onErrorReturnItem(T fallbackValue) → Stream<T>

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

错误时返回指定值

pairWith<R>(Stream<R> startMapper(T), Stream<R> endMapper(T)) → Stream<R>

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

开始和结束配对

retryWithDelay({int count = 3, Duration delay = const Duration(seconds: 1)}) → Stream<T>

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

重试操作符

sampleTime(Duration duration) → Stream<T>

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

按时间采样

sampleWith(Stream<void> sampler) → Stream<T>

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

采样操作符

scanValue<R>(R accumulator(R, T), R seed) → Stream<R>

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

扫描操作符

shareReplayValue({int bufferSize = 1, bool refCount = true}) → Stream<T>

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

缓存最后一个值

skipUntil(Stream<void> trigger) → Stream<T>

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

跳过直到某个条件

startWith(T value) → Stream<T>

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

在流开始前添加初始值

switchMapValue<R>(Stream<R> mapper(T)) → Stream<R>

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

切换到另一个Stream

throttleTime(Duration duration) → Stream<T>

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

节流操作符

timeoutTime(Duration duration, {void onTimeout(EventSink<T>)?}) → Stream<T>

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

超时操作符

whereIf(bool condition(T)) → Stream<T>

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

条件过滤

windowCount(int count, [int? startWindowEvery]) → Stream<Stream<T>>

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

按数量窗口

windowTime(Duration duration) → Stream<Stream<T>>

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

按时间窗口

windowWith(Stream<void> windowStream) → Stream<Stream<T>>

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

窗口操作符

withLatestFrom<U, R>(Stream<U> other, R combiner(T, U)) → Stream<R>

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

与另一个流的最新值组合

zipWith<U, R>(Stream<U> other, R combiner(T, U)) → Stream<R>

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

压缩值