Trait holochain::prelude::kitsune_p2p::dependencies::kitsune_p2p_types::tx2::tx2_adapter::EndpointAdapt

pub trait EndpointAdapt: 'static + Send + Sync + Unpin {
    fn debug(&self) -> Value;
    fn uniq(&self) -> Uniq;
    fn local_addr(&self) -> Result<TxUrl, KitsuneError>;
    fn local_cert(&self) -> Tx2Cert;
    fn connect(
        &self,
        url: TxUrl,
        timeout: KitsuneTimeout
    ) -> Pin<Box<dyn Future<Output = Result<(Arc<dyn ConAdapt + 'static>, Box<dyn InChanRecvAdapt<Item = Pin<Box<dyn Future<Output = Result<Box<dyn AsFramedReader + 'static, Global>, KitsuneError>> + Send + 'static, Global>>> + 'static, Global>), KitsuneError>> + Send + 'static, Global>>;
    fn is_closed(&self) -> bool;
    fn close(
        &self,
        code: u32,
        reason: &str
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'static, Global>>;
}

Expand description

Tx backend adapter represents a bound local endpoint.

Required Methods

fn debug(&self) -> Value

Capture a debugging internal state dump.

fn uniq(&self) -> Uniq

Get the opaque Uniq identifier for this endpoint.

fn local_addr(&self) -> Result<TxUrl, KitsuneError>

Get the string address (url) of this binding.

fn local_cert(&self) -> Tx2Cert

Get the local certificate digest.

fn connect(
    &self,
    url: TxUrl,
    timeout: KitsuneTimeout
) -> Pin<Box<dyn Future<Output = Result<(Arc<dyn ConAdapt + 'static>, Box<dyn InChanRecvAdapt<Item = Pin<Box<dyn Future<Output = Result<Box<dyn AsFramedReader + 'static, Global>, KitsuneError>> + Send + 'static, Global>>> + 'static, Global>), KitsuneError>> + Send + 'static, Global>>

Create a new outgoing connection to a remote.

fn is_closed(&self) -> bool

Check if this endpoint has closed.

fn close(
    &self,
    code: u32,
    reason: &str
) -> Pin<Box<dyn Future<Output = ()> + Send + 'static, Global>>

Shutdown this endpoint / all connections / all channels.

Implementors

impl EndpointAdapt for MockEndpointAdapt

Tx backend adapter represents a bound local endpoint.