pub struct ParallelGatewayActivity { /* private fields */ }Expand description
Parallel Gateway Activity
Implements Activity trait for ParallelGateway elements. Takes all outgoing flows (splitting) or waits for all incoming flows (joining).
Implementations§
Source§impl ParallelGatewayActivity
impl ParallelGatewayActivity
pub fn new(gateway: ParallelGateway) -> Self
Trait Implementations§
Source§impl Activity for ParallelGatewayActivity
impl Activity for ParallelGatewayActivity
Source§fn execute<'life0, 'life1, 'async_trait>(
&'life0 self,
context: &'life1 mut ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<ActivityResult, ActivityError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn execute<'life0, 'life1, 'async_trait>(
&'life0 self,
context: &'life1 mut ExecutionContext,
) -> Pin<Box<dyn Future<Output = Result<ActivityResult, ActivityError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Execute the activity Read more
Auto Trait Implementations§
impl Freeze for ParallelGatewayActivity
impl RefUnwindSafe for ParallelGatewayActivity
impl Send for ParallelGatewayActivity
impl Sync for ParallelGatewayActivity
impl Unpin for ParallelGatewayActivity
impl UnsafeUnpin for ParallelGatewayActivity
impl UnwindSafe for ParallelGatewayActivity
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