Struct Ipc

pub struct Ipc { /* private fields */ }

Unix Domain Sockets (IPC) transport.

Implementations

impl Ipc

pub async fn new<P: AsRef<Path>>(path: P) -> Result<Self>

Creates a new IPC transport from a given path.

IPC is only available on Unix.

Trait Implementations

impl BatchTransport for Ipc

type Batch = BatchResponse

The type of future this transport returns when a call is made.

fn send_batch<T: IntoIterator<Item = (RequestId, Call)>>( &self, requests: T, ) -> Self::Batch

Sends a batch of prepared RPC calls.

impl Clone for Ipc

fn clone(&self) -> Ipc

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Ipc

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

Formats the value using the given formatter.

impl DuplexTransport for Ipc

type NotificationStream = UnboundedReceiver<Value>

The type of stream this transport returns

fn subscribe(&self, id: SubscriptionId) -> Result<Self::NotificationStream>

Add a subscription to this transport

fn unsubscribe(&self, id: SubscriptionId) -> Result<()>

Remove a subscription from this transport

impl Transport for Ipc

type Out = SingleResponse

The type of future this transport returns when a call is made.

fn prepare(&self, method: &str, params: Vec<Value>) -> (RequestId, Call)

Prepare serializable RPC call for given method with parameters.

fn send(&self, id: RequestId, call: Call) -> Self::Out

Execute prepared RPC call.

fn execute(&self, method: &str, params: Vec<Value>) -> Self::Out

Execute remote method with given parameters.