vuo 0.1.1

An asynchronous stream processing library for Rust, built on Actix, providing a rich set of functional operators.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

//! This module contains all the actors that are used to implement stream operations.

// Existing actor modules
pub(crate) mod chunking_actor;
pub(crate) mod collector_actor;
pub(crate) mod concat_map_actor;
pub(crate) mod debounce_actor; // Added DebounceActor module
pub(crate) mod drain_actor;
pub(crate) mod drop_while_actor;
pub(crate) mod emits_actor;
pub(crate) mod eval_tap_actor; // Added EvalTapActor module
pub(crate) mod eval_map_actor;
pub(crate) mod filter_actor;
pub(crate) mod fold_actor;
pub(crate) mod group_within_actor; // Added GroupWithinActor module
pub(crate) mod inner_stream_proxy_actor;
pub(crate) mod interrupt_actor; // Added InterruptActor module
pub(crate) mod mapping_actor;
pub(crate) mod merge_actor; // Added Merge2Actor module
pub(crate) mod handle_error_with_actor; // Added for handleErrorWith
pub(crate) mod on_finalize_actor;
pub(crate) mod par_map_ordered_actor;
pub(crate) mod par_map_unordered_actor;
pub(crate) mod scan_actor;
pub(crate) mod take_actor;
pub(crate) mod take_while_actor;
pub(crate) mod throttle_actor; // Added ThrottleActor module // Added ParMapOrderedActor module
pub(crate) mod zip_actor; // Added ZipActor module

// Re-exports for easier access
pub(crate) use chunking_actor::ChunkingActor;
pub(crate) use collector_actor::CollectorActor;
pub(crate) use concat_map_actor::ConcatMapActor;
pub(crate) use debounce_actor::DebounceActor; // Added DebounceActor re-export
pub(crate) use drain_actor::DrainActor;
pub(crate) use drop_while_actor::DropWhileActor;
pub(crate) use emits_actor::EmitsActor; // Added EmitsActor re-export
pub(crate) use eval_tap_actor::EvalTapActor; // Added EvalTapActor re-export
pub(crate) use eval_map_actor::EvalMapActor;
pub(crate) use filter_actor::FilterActor;
pub(crate) use fold_actor::FoldActor;
pub(crate) use group_within_actor::GroupWithinActor; // Added GroupWithinActor re-export
pub(crate) use interrupt_actor::InterruptActor; // Added InterruptActor re-export
pub(crate) use mapping_actor::MappingActor;
pub(crate) use merge_actor::Merge2Actor; // Added Merge2Actor re-export
pub(crate) use handle_error_with_actor::{HandleErrorWithActor, PrimaryStreamSetupResult}; // Added for handleErrorWith
pub(crate) use on_finalize_actor::OnFinalizeActor;
pub(crate) use par_map_ordered_actor::ParMapOrderedActor;
pub(crate) use par_map_unordered_actor::ParMapUnorderedActor;
pub(crate) use scan_actor::ScanActor;
pub(crate) use take_actor::TakeActor;
pub(crate) use take_while_actor::TakeWhileActor;
pub(crate) use throttle_actor::ThrottleActor; // Added ThrottleActor re-export // Added ParMapOrderedActor re-export
pub(crate) use zip_actor::ZipActor; // Added ZipActor re-export