pub struct Connection;Expand description
Namespace for transport-agnostic lifecycle constructors.
Implementations§
Source§impl Connection
impl Connection
Sourcepub fn tls_client<A>(
addr: A,
server_name: ServerName<'static>,
client_config: Arc<ClientConfig>,
settings: ConnectionSettings,
) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>
pub fn tls_client<A>( addr: A, server_name: ServerName<'static>, client_config: Arc<ClientConfig>, settings: ConnectionSettings, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>
Opens a lifecycle-aware TLS client connection with the default chunk size.
Sourcepub fn graceful_shutdown<Mat>(
flow: Flow<Vec<u8>, Vec<u8>, Mat>,
) -> Flow<Vec<u8>, Vec<u8>, Mat>where
Mat: Send + 'static,
pub fn graceful_shutdown<Mat>(
flow: Flow<Vec<u8>, Vec<u8>, Mat>,
) -> Flow<Vec<u8>, Vec<u8>, Mat>where
Mat: Send + 'static,
Marks a connection flow as using graceful half-close on upstream finish.
Datum TCP/TLS connection flows already map upstream completion to
AsyncWriteExt::shutdown() and keep the read side alive. This helper is
an explicit API affordance for that behavior when a call site wants to
state the lifecycle intent.
Auto Trait Implementations§
impl Freeze for Connection
impl RefUnwindSafe for Connection
impl Send for Connection
impl Sync for Connection
impl Unpin for Connection
impl UnsafeUnpin for Connection
impl UnwindSafe for Connection
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage