pub struct GraphBuilder { /* private fields */ }Expand description
Mutable scratch state for assembling a graph inside a GraphDsl closure.
Tracks registered stages, their ports, the edges wired between them, and any
deferred wiring errors (raised by wire, which collects rather than
short-circuits). finish consumes it into a validated GraphBlueprint.
Implementations§
Source§impl GraphBuilder
impl GraphBuilder
pub fn add<G: GraphStage>(&mut self, stage: G) -> G::Shape
pub fn add_with_attributes<G: GraphStage>( &mut self, stage: G, attributes: Attributes, ) -> G::Shape
pub fn add_named<G: GraphStage>( &mut self, stage: G, name: impl Into<String>, ) -> G::Shape
pub fn connect<T: 'static>( &mut self, outlet: Outlet<T>, inlet: Inlet<T>, ) -> StreamResult<()>
pub fn connect_any( &mut self, outlet: AnyOutlet, inlet: AnyInlet, ) -> StreamResult<()>
pub fn import<S: Shape>(&mut self, graph: &PartialGraph<S>) -> StreamResult<S>
pub fn wire<W: WireSpec>(&mut self, spec: W) -> &mut Self
pub fn try_wire<W: WireSpec>(&mut self, spec: W) -> StreamResult<&mut Self>
Trait Implementations§
Source§impl Debug for GraphBuilder
impl Debug for GraphBuilder
Source§impl Default for GraphBuilder
impl Default for GraphBuilder
Source§fn default() -> GraphBuilder
fn default() -> GraphBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for GraphBuilder
impl !UnwindSafe for GraphBuilder
impl Freeze for GraphBuilder
impl Send for GraphBuilder
impl Sync for GraphBuilder
impl Unpin for GraphBuilder
impl UnsafeUnpin for GraphBuilder
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> 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