Tokio StreamExt [WIP]

使用新操作符的流扩展，这将随着时间的推移而增长。

请随意贡献！

待办事项

• [] 更好的readme
• [] RustDoc
• [] 进一步的操作符

操作符

去抖动

在给定的持续时间后稳定去抖动流。

ReceiverStream::new(self.input)
    .debounce(Duration::from_millis(80)),

distinct until changed

过滤事件，类似于最后一个值。

初始值始终被发射。

ReceiverStream::new(self.input)
    .distinct_until_changed(),

Switch Map

流的反应式组合。

switch_map(ReceiverStream::new(keyboard), move |value| {
    if value == 'k' {
        Some(ReceiverStream::new(gamepad))
    } else {
        Some(ReceiverStream::new(joystick))
    }
});

Combine Latest

从所有流中收集一个值并切换到实时模式。从现在开始，将发射所有新的组合。

switch_map(ReceiverStream::new(keyboard), move |value| {
    if value == 'k' {
        Some(ReceiverStream::new(gamepad))
    } else {
        Some(ReceiverStream::new(joystick))
    }
});