Trait samotop::io::client::Connector[][src]

pub trait Connector: Send + Sync + Debug {
    type Stream: 'static + Send + Sync + Unpin + MayBeTls + AsyncRead + AsyncWrite;
    pub fn connect<'s, 'c, 'a, C>(
        &'s self,
        configuration: &'c C
    ) -> Pin<Box<dyn Future<Output = Result<Self::Stream, Error>> + 'a + Send + Sync, Global>>

Notable traits for Pin<P>

impl<P> Future for Pin<P> where
    P: Unpin + DerefMut,
    <P as Deref>::Target: Future
type Output = <<P as Deref>::Target as Future>::Output;

    where
        's: 'a,
        'c: 'a,
        C: ConnectionConfiguration
; }

Associated Types

type Stream: 'static + Send + Sync + Unpin + MayBeTls + AsyncRead + AsyncWrite[src]

Loading content...

Required methods

pub fn connect<'s, 'c, 'a, C>(
    &'s self,
    configuration: &'c C
) -> Pin<Box<dyn Future<Output = Result<Self::Stream, Error>> + 'a + Send + Sync, Global>>

Notable traits for Pin<P>

impl<P> Future for Pin<P> where
    P: Unpin + DerefMut,
    <P as Deref>::Target: Future
type Output = <<P as Deref>::Target as Future>::Output;
where
    's: 'a,
    'c: 'a,
    C: ConnectionConfiguration
[src]

This provider of connectivity takes care of resolving given address (which could be an IP, FQDN, URL...), establishing a connection and enabling (or not) TLS upgrade.

Loading content...

Implementors

impl<TLS> Connector for TcpConnector<TLS> where
    TLS: TlsProvider + Sync + Send + 'static, 
[src]

type Stream = TlsCapable

pub fn connect<'s, 'c, 'a, C>(
    &'s self,
    configuration: &'c C
) -> Pin<Box<dyn Future<Output = Result<<TcpConnector<TLS> as Connector>::Stream, Error>> + 'a + Send + Sync, Global>>

Notable traits for Pin<P>

impl<P> Future for Pin<P> where
    P: Unpin + DerefMut,
    <P as Deref>::Target: Future
type Output = <<P as Deref>::Target as Future>::Output;
where
    's: 'a,
    'c: 'a,
    C: ConnectionConfiguration + Sync
[src]

This provider of connectivity takes care of resolving given address (which could be an IP, FQDN, URL...), establishing a connection and enabling (or not) TLS upgrade.

impl<TLS> Connector for UnixConnector<TLS> where
    TLS: TlsProvider + Sync + Send + 'static, 
[src]

type Stream = TlsCapable

pub fn connect<'s, 'c, 'a, C>(
    &'s self,
    configuration: &'c C
) -> Pin<Box<dyn Future<Output = Result<<UnixConnector<TLS> as Connector>::Stream, Error>> + 'a + Send + Sync, Global>>

Notable traits for Pin<P>

impl<P> Future for Pin<P> where
    P: Unpin + DerefMut,
    <P as Deref>::Target: Future
type Output = <<P as Deref>::Target as Future>::Output;
where
    's: 'a,
    'c: 'a,
    C: ConnectionConfiguration + Sync
[src]

This provider of connectivity takes care of resolving given address (which could be an IP, FQDN, URL...), establishing a connection and enabling (or not) TLS upgrade.

Loading content...