Реактивное программирование в Rust: библиотеки и примеры |…

Реактивное программирование в Rust: обзор инструментов и примеры кода

Реактивное программирование — это парадигма, ориентированная на асинхронные потоки данных и распространение изменений. В экосистеме Rust она реализуется через мощные библиотеки, такие как RxRust (Reactive Extensions), futures-rs и async-std. Эти инструменты позволяют строить элегантные, отказоустойчивые и высокопроизводительные системы, от GUI-приложений до сетевых сервисов. В этой статье мы разберём ключевые концепции, покажем практические примеры и поможем выбрать подходящую библиотеку для вашего проекта на Rust.

Основные библиотеки для реактивного программирования в Rust

Наиболее популярные библиотеки для реактивного программирования в Rust включают:

RxRust — порт ReactiveX (Rx). Предоставляет Observable, Observer, операторы map, filter, merge и другие. Идеально подходит для обработки событий и потоков данных.
futures-rs — базовая библиотека для асинхронных вычислений. Включает Stream, Future, Sink. Лежит в основе многих реактивных систем.
async-std — асинхронная стандартная библиотека. Предоставляет async-версии файлового ввода-вывода, сетевых операций и каналы (channels) для реактивных потоков.
tokio — асинхронный runtime с поддержкой многопоточности. Часто используется в связке с futures-rs для построения реактивных сетевых приложений.

Пример 1: Использование RxRust для обработки событий

RxRust позволяет создавать Observable из итераторов, событий или асинхронных источников. Ниже — простой пример генерации чисел, фильтрации и подписки на поток:

use rxrust::prelude::*;

fn main() {
    // Создаём Observable из диапазона чисел
    observable::from_iter(1..10)
        .filter(|x| x % 2 == 0)       // Оставляем только чётные
        .map(|x| x * 10)              // Умножаем на 10
        .subscribe(
            |x| println!("Получено: {}", x),
            |err| eprintln!("Ошибка: {}", err),
            || println!("Поток завершён"),
        );
}

Результат выполнения:

Получено: 20
Получено: 40
Получено: 60
Получено: 80
Поток завершён

Пример 2: Асинхронные потоки с futures-rs

Библиотека futures-rs предоставляет типаж Stream, который является асинхронным аналогом Iterator. Следующий пример демонстрирует создание потока, его трансформацию и сбор результатов:

use futures::stream::{self, StreamExt};

#[tokio::main]
async fn main() {
    let stream = stream::iter(1..=5)
        .map(|x| x * x)
        .filter(|x| futures::future::ready(x % 2 == 0));

    let results: Vec<i32> = stream.collect().await;
    println!("Квадраты чётных чисел: {:?}", results);
}

Вывод:

Квадраты чётных чисел: [4, 16]

Пример 3: Реактивные каналы в async-std

Каналы (channels) — основа реактивных систем. Библиотека async-std предоставляет многопользовательские каналы, которые можно использовать для передачи событий между задачами:

use async_std::sync::channel;
use async_std::task;

fn main() {
    let (sender, receiver) = channel::unbounded::<String>();

    // Задача-отправитель
    task::spawn(async move {
        sender.send("Привет".to_string()).await.unwrap();
        sender.send("Мир".to_string()).await.unwrap();
    });

    // Задача-получатель (реактивный слушатель)
    task::block_on(async {
        while let Some(msg) = receiver.recv().await {
            println!("Получено сообщение: {}", msg);
        }
    });
}

Этот паттерн лежит в основе архитектуры событийно-ориентированных приложений на Rust.

Сравнение библиотек и рекомендации

RxRust — выбирайте для сложных цепочек преобразований данных, похожих на RxJS или RxJava. Подходит для GUI, обработки пользовательских событий.
futures-rs + tokio — стандартный выбор для высоконагруженных сетевых сервисов, микросервисов, WebSocket-соединений.
async-std — хорош для написания асинхронного к