fluxion-core 0.8.0

Core traits and types for ordered stream processing
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

// Copyright 2025 Umberto Gotti <umberto.gotti@umbertogotti.dev>
// Licensed under the Apache License, Version 2.0
// http://www.apache.org/licenses/LICENSE-2.0

use crate::Timestamped;
use core::fmt::Debug;

/// The standard trait for items flowing through Fluxion streams.
///
/// This trait aggregates all the necessary bounds for a type to be used
/// with Fluxion operators. It ensures the type is:
/// - Timestamped (for ordering)
/// - Thread-safe (Send + Sync)
/// - Movable (Unpin)
/// - Debuggable
/// - Orderable
/// - 'static (owned data)
///
/// # Automatic Implementation
///
/// This trait is automatically implemented for any type that satisfies the bounds.
///
/// For multi-threaded runtimes (tokio, smol, async-std), this requires `Send + Sync`.
/// For single-threaded runtimes (wasm, embassy), these bounds are not required.
// Multi-threaded runtimes (tokio/smol/async-std) - requires Send + Sync
#[cfg(any(
    all(feature = "runtime-tokio", not(target_arch = "wasm32")),
    feature = "runtime-smol",
    feature = "runtime-async-std"
))]
pub trait Fluxion: Timestamped + Clone + Send + Sync + Unpin + 'static + Debug + Ord
where
    Self::Inner: Clone + Send + Sync + Unpin + 'static + Debug + Ord,
{
}

#[cfg(any(
    all(feature = "runtime-tokio", not(target_arch = "wasm32")),
    feature = "runtime-smol",
    feature = "runtime-async-std"
))]
impl<T> Fluxion for T
where
    T: Timestamped + Clone + Send + Sync + Unpin + 'static + Debug + Ord,
    T::Inner: Clone + Send + Sync + Unpin + 'static + Debug + Ord,
{
}

// Single-threaded runtimes (wasm/embassy) - no Send + Sync required
#[cfg(not(any(
    all(feature = "runtime-tokio", not(target_arch = "wasm32")),
    feature = "runtime-smol",
    feature = "runtime-async-std"
)))]
pub trait Fluxion: Timestamped + Clone + Unpin + 'static + Debug + Ord
where
    Self::Inner: Clone + Unpin + 'static + Debug + Ord,
{
}

#[cfg(not(any(
    all(feature = "runtime-tokio", not(target_arch = "wasm32")),
    feature = "runtime-smol",
    feature = "runtime-async-std"
)))]
impl<T> Fluxion for T
where
    T: Timestamped + Clone + Unpin + 'static + Debug + Ord,
    T::Inner: Clone + Unpin + 'static + Debug + Ord,
{
}