福罗普

一个为Rust设计的函数式响应式流库。

• 小型 (~20 个操作)
• 同步
• 无依赖
• 是 FRP (哈哈！)

基于André Staltz的JavaScript库 xstream 设计，该库很好地将响应式扩展 (Rx) 的概念简化到最基本的形式。

这个库并不是按照Conal Elliot的定义那样是 FRP (函数式响应式编程)，而是一种既函数式又响应式的设计范式。 为什么我不能说FRP但我确实做到了。

示例

use froop::{Sink, Stream};

// A sink is an originator of events that form a stream.
let sink: Sink<u32> = Stream::sink();

// Map the even numbers to their square.
let stream: Stream<u32> = sink.stream()
    .filter(|i| i % 2 == 0)
    .map(|i| i * i);

// Print the result
stream.subscribe(|i| if let Some(i) = i {
    println!("{}", i)
});

// Send numbers into the sink.
for i in 0..10 {
    sink.update(i);
}
sink.end();

想法

函数式响应式编程是函数式编程 (FP) 的良好基础。逐步组合互锁操作的步骤是一种相对简单的方法，可以将FP结构应用于软件。

同步

处理作为时间值（或事件）的流的库通常将数据从A点移动到B点的概念与转换数据的算子混淆。结果是，库必须处理数据队列、队列长度和背压。

福罗普没有队列

将数据更新到操作树的每个 Sink::update() 都以同步方式执行。福罗普没有调度“稍后”的算子，即没有 delay() 或其他时间移位操作。

这也意味着福罗普也没有内部线程、future等。

线程安全

福罗普树中的每个部分都是线程安全的。您可以将在另一个线程中移动 Sink，或订阅和传播在UI主线程上。调用 Sink::update() 的线程执行整个树。