futuresdr 0.6.0

An Experimental Async SDR Runtime for Heterogeneous Architectures.
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

#![warn(missing_docs)]
#![allow(incomplete_features)]
#![feature(return_type_notation)]
#![feature(associated_type_defaults)]
#![feature(specialization)]
#![feature(where_clause_attrs)]
#![recursion_limit = "512"]

//! An experimental asynchronous SDR runtime for heterogeneous architectures that is:
//! * **Extensible**: custom buffers (supporting accelerators like GPUs and FPGAs) and custom schedulers (optimized for your application).
//! * **Asynchronous**: solving long-standing issues around IO, blocking, and timers.
//! * **Portable**: Linux, Windows, Mac, WASM, Android, and prime support for embedded platforms through a REST API and web-based GUIs.
//! * **Fast**: SDR go brrr!
//!
//! ## Example
//! An example flowgraph that forwards 123 zeros into a sink:
//! ```
//! use futuresdr::blocks::Head;
//! use futuresdr::blocks::NullSink;
//! use futuresdr::blocks::NullSource;
//! use futuresdr::prelude::*;
//!
//! fn main() -> Result<()> {
//!     let mut fg = Flowgraph::new();
//!
//!     let src = NullSource::<u8>::new();
//!     let head = Head::<u8>::new(123);
//!     let snk = NullSink::<u8>::new();
//!
//!     connect!(fg, src > head > snk);
//!
//!     Runtime::new().run(fg)?;
//!
//!     Ok(())
//! }
//! ```
//!
//! ## Main Entry Points
//! - [`blocks`] Library of common blocks that are not tied to a specific technology.
//! - [`runtime`] Runtime APIs for constructing, running, and interacting with flowgraphs.
//! - [`prelude`] Imports for constructing, running, and interacting with flowgraphs.
//!
//! ## Custom Blocks
//! To implement custom blocks or other runtime extensions, use
//! [`runtime::dev::prelude`].

// make the futuresdr crate available in the library to allow referencing it as
// futuresdr internally, which simplifies proc macros.
extern crate self as futuresdr;
/// Logging macro
#[macro_use]
pub extern crate tracing;

// re-exports
#[cfg(not(target_arch = "wasm32"))]
pub use async_net;
pub use bytemuck;
pub use futuredsp;
pub use futures;
#[cfg(all(feature = "audio", not(target_arch = "wasm32")))]
pub use hound;
pub use num_complex;
pub use num_integer;
#[cfg(feature = "seify")]
pub use seify;

/// Library of common blocks that are not tied to a specific technology.
pub mod blocks;
pub mod runtime;

/// Prelude for building and controlling flowgraphs.
///
/// These imports cover the usual application-facing API: flowgraph
/// construction, runtime execution, message passing, common IDs, and logging.
/// Custom block implementations should use [`crate::runtime::dev::prelude`]
/// instead.
pub mod prelude {
    pub use futures::future::FutureExt as _;
    pub use futures::sink::SinkExt as _;
    pub use futures::stream::StreamExt as _;
    pub use futuresdr::runtime::BlockId;
    pub use futuresdr::runtime::BlockRef;
    pub use futuresdr::runtime::Error;
    pub use futuresdr::runtime::Flowgraph;
    pub use futuresdr::runtime::FlowgraphBlockHandle;
    pub use futuresdr::runtime::FlowgraphHandle;
    pub use futuresdr::runtime::FlowgraphId;
    pub use futuresdr::runtime::LocalDomain;
    pub use futuresdr::runtime::LocalDomainContext;
    pub use futuresdr::runtime::Pmt;
    pub use futuresdr::runtime::PortId;
    pub use futuresdr::runtime::PortIndex;
    pub use futuresdr::runtime::PortName;
    pub use futuresdr::runtime::Result;
    pub use futuresdr::runtime::RunningFlowgraph;
    pub use futuresdr::runtime::Runtime;
    pub use futuresdr::runtime::TerminatedFlowgraph;
    pub use futuresdr::runtime::Timer;
    #[cfg(not(target_arch = "wasm32"))]
    pub use futuresdr::runtime::block_on;
    pub use futuresdr::runtime::channel::mpsc;
    pub use futuresdr::runtime::macros::connect;
    pub use futuresdr::runtime::macros::connect_async;
    pub use futuresdr::tracing::debug;
    pub use futuresdr::tracing::error;
    pub use futuresdr::tracing::info;
    pub use futuresdr::tracing::trace;
    pub use futuresdr::tracing::warn;
    pub use num_complex::Complex;
    pub use num_complex::Complex32;
    pub use num_complex::Complex64;
}