Mapper<T, R> class

对某个io进行变换

Inheritance

• Object
• BaseIO<R>
• Mapper

Constructors

Mapper({required BaseIO<T> upstream, required String semantics, required R mapper(T), R? seedValue})

Properties

hashCode → int

The hash code for this object.

no setter, inherited

isDisposed → bool

no setter, inherited

latest ↔ R

最新的值

getter/setter pair, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

stream → Stream<R>

no setter

Methods

addError(Object error, [StackTrace? stackTrace]) → void

inherited

dispose() → void

关闭流

override

distinct([bool test(R previous, R next)?]) → Stream<R>

inherited

first([bool cancelSubscription = false]) → Future<R>

输出Future, cancelSubscription决定是否取消订阅

invalidate([R? newData]) → void

重新发送数据 用户修改数据后刷新的场景

inherited

map<S>(S convert(R event)) → Stream<S>

inherited

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

pull() → void

reset() → void

清理保存的值, 恢复成初始状态

inherited

runtimeSummary() → String

运行时概要

inherited

sample(Duration duration) → Stream<R>

inherited

toString() → String

A string representation of this object.

inherited

where(bool test(R event)) → Stream<R>

inherited

whereType<R>() → Stream<R>

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited