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
//! Building and running a graph.
//!
//! [`PipelineBuilder`] assembles one; [`Pipeline`] owns it at runtime — the
//! source threads, the control cascade, the shared
//! [`Clock`](crate::clock::Clock), the [`Bus`](crate::bus::Bus), and the
//! [`PipelineGraph`](crate::graph::PipelineGraph). [`ChainBuilder`] and
//! [`DetachedBranch`] are how a branch is described before it is attached, so
//! that wiring can fail without leaving a half-built graph behind.
//!
//! Ending a pipeline is two different requests, not one:
//! [`Pipeline::finish`] emits ordered EOS from the source and lets it drain
//! every stage that holds delayed data, while [`Pipeline::stop`] abandons
//! that work.
pub use PipelineBuilder;
pub use ;
pub use Pipeline;
use cratePpLog;
use crate::;
use ;