Struct IpcConnect

pub struct IpcConnect<T> { /* private fields */ }

Available on crate feature ipc only.

An IPC Connection object.

Implementations

impl<T> IpcConnect<T>

pub const fn new(inner: T) -> IpcConnect<T>

where IpcConnect<T>: PubSubConnect,

Create a new IPC connection object for any type T that can be converted into IpcConnect<T>.

Trait Implementations

impl<T> Clone for IpcConnect<T>

where T: Clone,

fn clone(&self) -> IpcConnect<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for IpcConnect<T>

where T: Debug,

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

Formats the value using the given formatter.

impl From<CString> for IpcConnect<CString>

fn from(inner: CString) -> IpcConnect<CString>

Converts to this type from the input type.

impl From<OsString> for IpcConnect<OsString>

fn from(inner: OsString) -> IpcConnect<OsString>

Converts to this type from the input type.

impl From<PathBuf> for IpcConnect<PathBuf>

fn from(inner: PathBuf) -> IpcConnect<PathBuf>

Converts to this type from the input type.

impl From<String> for IpcConnect<String>

fn from(inner: String) -> IpcConnect<String>

Converts to this type from the input type.

impl PubSubConnect for IpcConnect<CString>

fn is_local(&self) -> bool

Returns true if the transport connects to a local resource.

async fn connect( &self, ) -> Result<ConnectionHandle, RpcError<TransportErrorKind>>

Spawn the backend, returning a handle to it.

fn try_reconnect( &self, ) -> impl Send + Future<Output = Result<ConnectionHandle, RpcError<TransportErrorKind>>>

Attempt to reconnect the transport.

fn into_service( self, ) -> impl Send + Future<Output = Result<PubSubFrontend, RpcError<TransportErrorKind>>>

Convert the configuration object into a service with a running backend.

impl PubSubConnect for IpcConnect<OsString>

fn is_local(&self) -> bool

Returns true if the transport connects to a local resource.

async fn connect( &self, ) -> Result<ConnectionHandle, RpcError<TransportErrorKind>>

Spawn the backend, returning a handle to it.

fn try_reconnect( &self, ) -> impl Send + Future<Output = Result<ConnectionHandle, RpcError<TransportErrorKind>>>

Attempt to reconnect the transport.

fn into_service( self, ) -> impl Send + Future<Output = Result<PubSubFrontend, RpcError<TransportErrorKind>>>

Convert the configuration object into a service with a running backend.

impl PubSubConnect for IpcConnect<PathBuf>

fn is_local(&self) -> bool

Returns true if the transport connects to a local resource.

async fn connect( &self, ) -> Result<ConnectionHandle, RpcError<TransportErrorKind>>

Spawn the backend, returning a handle to it.

fn try_reconnect( &self, ) -> impl Send + Future<Output = Result<ConnectionHandle, RpcError<TransportErrorKind>>>

Attempt to reconnect the transport.

fn into_service( self, ) -> impl Send + Future<Output = Result<PubSubFrontend, RpcError<TransportErrorKind>>>

Convert the configuration object into a service with a running backend.

impl PubSubConnect for IpcConnect<String>

fn is_local(&self) -> bool

Returns true if the transport connects to a local resource.

async fn connect( &self, ) -> Result<ConnectionHandle, RpcError<TransportErrorKind>>

Spawn the backend, returning a handle to it.

fn try_reconnect( &self, ) -> impl Send + Future<Output = Result<ConnectionHandle, RpcError<TransportErrorKind>>>

Attempt to reconnect the transport.

fn into_service( self, ) -> impl Send + Future<Output = Result<PubSubFrontend, RpcError<TransportErrorKind>>>

Convert the configuration object into a service with a running backend.