Struct EmbeddedWorkflowTransport 

pub struct EmbeddedWorkflowTransport { /* private fields */ }

Transport backed by an in-process aion::Engine.

Implementations

impl EmbeddedWorkflowTransport

pub fn new(engine: Arc<Engine>) -> Self

Creates an embedded transport for engine.

Trait Implementations

impl WorkflowTransport for EmbeddedWorkflowTransport

fn start_workflow<'life0, 'async_trait>( &'life0 self, request: ProtoStartWorkflowRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoStartWorkflowResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends StartWorkflow over the transport.

fn signal<'life0, 'async_trait>( &'life0 self, request: ProtoSignalRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoSignalResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Signal over the transport.

fn query<'life0, 'async_trait>( &'life0 self, request: ProtoQueryRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoQueryResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Query over the transport.

fn cancel<'life0, 'async_trait>( &'life0 self, request: ProtoCancelRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoCancelResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Cancel over the transport.

fn reopen<'life0, 'async_trait>( &'life0 self, request: ProtoReopenRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoReopenResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Reopen over the transport.

fn pause<'life0, 'async_trait>( &'life0 self, request: ProtoPauseRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoPauseResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Pause over the transport (#204).

fn resume<'life0, 'async_trait>( &'life0 self, request: ProtoResumeRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoResumeResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends Resume over the transport (#204).

fn list_workflows<'life0, 'async_trait>( &'life0 self, request: ProtoListWorkflowsRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoListWorkflowsResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends ListWorkflows over the transport.

fn describe_workflow<'life0, 'async_trait>( &'life0 self, request: ProtoDescribeWorkflowRequest, ) -> Pin<Box<dyn Future<Output = Result<ProtoDescribeWorkflowResponse, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends DescribeWorkflow over the transport.

fn subscribe<'life0, 'async_trait>( &'life0 self, request: SubscriptionRequest, resume_from_sequence: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<SubscriptionAttempt, ClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Opens an event subscription attempt.