pub struct StageSpec { /* private fields */ }Expand description
The blueprint description of a stage: its name, erased ports, the internal
kind the executor switches on, async-boundary flag, and attributes.
Construct one with StageSpec::opaque for a custom stage that runs its own
GraphStageLogic; built-in stages use the crate-internal constructors.
Implementations§
Source§impl StageSpec
impl StageSpec
pub fn opaque( name: impl Into<String>, inlets: Vec<AnyInlet>, outlets: Vec<AnyOutlet>, ) -> Self
pub fn name(&self) -> &str
pub fn inlets(&self) -> &[AnyInlet]
pub fn outlets(&self) -> &[AnyOutlet]
pub fn attributes(&self) -> &Attributes
pub fn with_attributes(self, attributes: Attributes) -> Self
pub fn add_attributes(self, attributes: Attributes) -> Self
pub fn named(self, name: impl Into<String>) -> Self
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for StageSpec
impl !UnwindSafe for StageSpec
impl Freeze for StageSpec
impl Send for StageSpec
impl Sync for StageSpec
impl Unpin for StageSpec
impl UnsafeUnpin for StageSpec
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage