Flows.rs: Derive Macros
"Τὰ πάντα ῥεῖ καὶ οὐδὲν μένει" — Heraclitus
Derive macros for flow-based programming (FBP) in Rust. This package is part of Flows.rs, a growing shrink-wrap inventory of standard, reusable dataflow blocks for common use cases.
[!TIP] 🚧 We are building in public. This is presently under heavy construction.
[Features] | [Prerequisites] | [Installation] | [Examples] | [Reference] | [Development]
✨ Features
- Provides components for flow-based programming (FBP) based on Tokio.
- Enables dataflow systems through reusable components called blocks.
- Built on the dataflow primitives provided by the Async-Flow project.
- Supports opting out of any feature using comprehensive feature flags.
- Adheres to the Rust API Guidelines in its naming conventions.
- Cuts red tape: 100% free and unencumbered public domain software.
🛠️ Prerequisites
- Rust 1.85+ (2024 edition)
⬇️ Installation
Installation via Cargo
👉 Examples
Importing the Library
use *;
📚 Reference
Packages
| Package | Summary | Crate | Documentation |
|---|---|---|---|
| flows | Flow-based programming (FBP). |  |
 |
| flows-arrow | Flow-based data processing with Apache Arrow. |  |
 |
| flows-audio | Flow-based audio processing. |  |
 |
| flows-datafusion | Flow-based query processing with Apache DataFusion. |  |
 |
| flows-derive | Derive macros for flow-based programming (FBP). | |
|
| flows-hash | Flow-based cryptographic hashing. |  |
 |
| flows-http | Flow-based HTTP requests & responses. |  |
 |
| flows-image | Flow-based image processing. |  |
 |
| flows-io | Flow-based I/O readers & writers. |  |
 |
| flows-json | Flow-based JSON encoding & decoding. |  |
 |
| flows-math | Flow-based mathematical operations. |  |
 |
| flows-rand | Flow-based random number generation. |  |
 |
| flows-text | Flow-based text processing. |  |
 |
Integrations
TBD
Glossary
-
System: A collection of blocks that are connected together. Systems are the top-level entities in dataflow programs.
-
Block: An encapsulated system component that processes messages. Blocks are the autonomous units of computation in a system.
-
Port: A named connection point on a block that sends or receives messages. Ports are the only interfaces through which blocks communicate with each other.
-
Message: A unit of data that flows between blocks in a system, from port to port. Any Rust type that implements the
Send + Sync + 'statictraits can be used as a message.
👨💻 Development
