pub struct Chain { /* private fields */ }Expand description
Data processing chain.
Implementations§
Source§impl Chain
impl Chain
pub fn new(meta: PipelineMeta, segments: Vec<Segment>) -> Self
pub fn meta(&self) -> &PipelineMeta
pub fn segments(&self) -> &[Segment]
pub fn into_segments(self) -> Vec<Segment>
Sourcepub fn datagram_hazard(&self) -> Option<&str>
pub fn datagram_hazard(&self) -> Option<&str>
The first stage on this chain that must not carry datagrams, if any.
A subprocess never can: its stdin and stdout are byte streams, so message boundaries are gone the moment bytes cross the pipe.
pub fn stage_names(&self) -> Vec<&str>
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Chain
impl !Sync for Chain
impl !UnwindSafe for Chain
impl Freeze for Chain
impl Send for Chain
impl Unpin for Chain
impl UnsafeUnpin for Chain
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more