Struct MonitoredConnection

pub struct MonitoredConnection<C, M> {
    inner: C,
    monitor: M,
}

Fields

inner: C

monitor: M

Implementations

impl<C, M> MonitoredConnection<C, M>

pub fn new(connector: C, monitor: M) -> Self

fn project_into(this: Pin<&mut Self>) -> (Pin<&mut C>, &mut M)

fn hyper_tokio_delegate( self: Pin<&mut Self>, ) -> TokioIo<MonitoredConnection<TokioIo<Pin<&mut C>>, &mut M>>

Delegate async read/write traits between tokio and hyper.

Trait Implementations

impl<C: AsyncRead, M: MonitorAsyncReadWrite> AsyncRead for MonitoredConnection<C, M>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl<C: AsyncWrite, M: MonitorAsyncReadWrite> AsyncWrite for MonitoredConnection<C, M>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl<C: Clone, M: Clone> Clone for MonitoredConnection<C, M>

fn clone(&self) -> MonitoredConnection<C, M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Connected, M> Connected for MonitoredConnection<C, M>

type ConnectInfo = <C as Connected>::ConnectInfo

The connection info type the IO resources generates.

fn connect_info(&self) -> Self::ConnectInfo

Create type holding information about the connection.

impl<C: Connection, M> Connection for MonitoredConnection<C, M>

fn connected(&self) -> Connected

Return metadata describing the connection.

impl<C: Connection, M> Connection for MonitoredConnection<C, M>

fn connected(&self) -> Connected

Return metadata describing the connection.

impl<C: Read, M: MonitorAsyncReadWrite> Read for MonitoredConnection<C, M>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: ReadBufCursor<'_>, ) -> Poll<Result<(), Error>>

Attempts to read bytes into the buf.

impl<C: Service<Uri>, M: MonitorNewConnection + Clone + 'static> Service<Uri> for MonitoredConnection<C, M>

where C::Future: 'static,

type Error = <C as Service<Uri>>::Error

Errors produced by the service.

type Response = MonitoredConnection<<C as Service<Uri>>::Response, <M as MonitorNewConnection>::ConnectionMonitor>

Responses given by the service.

type Future = impl Future<Output = Result<<MonitoredConnection<C, M> as Service<Uri>>::Response, <MonitoredConnection<C, M> as Service<Uri>>::Error>> + 'static

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, uri: Uri) -> Self::Future

Process the request and return the response asynchronously.

impl<C: Service<Uri>, M: MonitorNewConnection + Clone + 'static> Service<Uri> for MonitoredConnection<C, M>

where C::Future: 'static,

type Error = <C as Service<Uri>>::Error

Errors produced by the service.

type Response = MonitoredConnection<<C as Service<Uri>>::Response, <M as MonitorNewConnection>::ConnectionMonitor>

Responses given by the service.

type Future = impl Future<Output = Result<<MonitoredConnection<C, M> as Service<Uri>>::Response, <MonitoredConnection<C, M> as Service<Uri>>::Error>> + 'static

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, uri: Uri) -> Self::Future

Process the request and return the response asynchronously.

impl<Con, E, C: Stream<Item = Result<Con, E>>, M: MonitorNewConnection> Stream for MonitoredConnection<C, M>

where Con: Connected<ConnectInfo = TcpConnectInfo>,

type Item = Result<MonitoredConnection<Con, <M as MonitorNewConnection>::ConnectionMonitor>, E>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<C: Write, M: MonitorAsyncReadWrite> Write for MonitoredConnection<C, M>

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the destination.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object.

fn poll_shutdown( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to shut down this writer.

fn is_write_vectored(&self) -> bool

Returns whether this writer has an efficient poll_write_vectored implementation.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

impl<'__pin, C, M> Unpin for MonitoredConnection<C, M>

where __Origin<'__pin, C, M>: Unpin,