Struct workflow_core::channel::DuplexChannel

pub struct DuplexChannel<T = (), R = ()> {
    pub request: Channel<T>,
    pub response: Channel<R>,
}

DuplexChannel contains 2 channels request and response meant to provide for a request/response pattern. This is useful for any type of signaling, but especially during task termination, where you can request a task to terminate and wait for a response confirming its termination.

Fields

request: Channel<T>

response: Channel<R>

Implementations

impl<T, R> DuplexChannel<T, R>

pub fn unbounded() -> Self

pub fn oneshot() -> Self

pub async fn signal(&self, msg: T) -> Result<R, ChannelError<T>>

Trait Implementations

impl<T: Clone, R: Clone> Clone for DuplexChannel<T, R>

fn clone(&self) -> DuplexChannel<T, R>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug, R: Debug> Debug for DuplexChannel<T, R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.