Struct DtxConnection 

pub struct DtxConnection<S> { /* private fields */ }

A managed DTX connection with channel multiplexing and method call support.

Implementations

impl<S: AsyncRead + AsyncWrite + Unpin + Send> DtxConnection<S>

pub fn new(stream: S) -> Self

pub async fn send_raw(&mut self, data: &[u8]) -> Result<(), DtxError>

pub async fn send_ack(&mut self, msg: &DtxMessage) -> Result<(), DtxError>

pub async fn recv(&mut self) -> Result<DtxMessage, DtxError>

Receive the next fully-assembled DTX message, transparently reassembling fragments.

pub async fn request_channel( &mut self, service_name: &str, ) -> Result<i32, DtxError>

Request a DTX channel by service name. Returns the assigned channel code.

pub async fn method_call( &mut self, channel_code: i32, selector: &str, args: &[PrimArg], ) -> Result<DtxMessage, DtxError>

Call a method on a channel and wait for the response.

pub async fn method_call_async( &mut self, channel_code: i32, selector: &str, args: &[PrimArg], ) -> Result<(), DtxError>

Fire-and-forget method call.