Struct UnixIpcTransport 

pub struct UnixIpcTransport { /* private fields */ }

Unix Domain Socket transport for local IPC

Implementations

impl UnixIpcTransport

pub async fn new_server( socket_path: impl AsRef<Path>, capacity: usize, ) -> Result<Self>

Create a new Unix IPC transport as a server (consumer side)

pub async fn new_client( socket_path: impl AsRef<Path>, capacity: usize, ) -> Result<Self>

Create a new Unix IPC transport as a client (publisher side)

Trait Implementations

impl Clone for UnixIpcTransport

fn clone(&self) -> UnixIpcTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for UnixIpcTransport

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl TransportChannel for UnixIpcTransport

fn send_batch<'life0, 'async_trait>( &'life0 self, messages: Vec<CanonicalMessage>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send a batch of messages

fn recv_batch<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<CanonicalMessage>>> + Send + 'async_trait>>

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

Receive a batch of messages (blocking)

fn try_recv_batch(&self) -> Result<Option<Vec<CanonicalMessage>>>

Try to receive a batch without blocking

fn len(&self) -> usize

Get the current number of batches in the channel

fn capacity(&self) -> Option<usize>

Get the capacity of the channel

fn is_closed(&self) -> bool

Check if the channel is closed

fn close(&self)

Close the channel

fn is_empty(&self) -> bool

Check if the channel is empty