Struct IpcConnect

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

An IPC Connection object.

Implementations

impl<T> IpcConnect<T>

pub const fn new(inner: T) -> Self

where Self: PubSubConnect,

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

Trait Implementations

impl<T: Clone> Clone for IpcConnect<T>

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> Debug for IpcConnect<T>

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

Formats the value using the given formatter.

impl From<IpcConnect<OsString>> for OsString

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

Converts to this type from the input type.

impl From<IpcConnect<PathBuf>> for PathBuf

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

Converts to this type from the input type.

impl From<IpcConnect<String>> for String

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

Converts to this type from the input type.

impl From<OsString> for IpcConnect<OsString>

fn from(inner: OsString) -> Self

Converts to this type from the input type.

impl From<PathBuf> for IpcConnect<PathBuf>

fn from(inner: PathBuf) -> Self

Converts to this type from the input type.

impl From<String> for IpcConnect<String>

fn from(inner: String) -> Self

Converts to this type from the input type.

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, TransportError>

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, TransportError>

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, TransportError>

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.