Struct Resource

pub struct Resource<R, C: Clock> { /* private fields */ }

A speed-limited wrapper of a byte stream.

The Resource can be used to limit speed of

• AsyncRead
• AsyncWrite

Just like Limiter, the delay is inserted after the data are sent or received, in which we know the exact amount of bytes transferred to give an accurate delay. The instantaneous speed can exceed the limit if many read/write tasks are started simultaneously. Therefore, restricting the concurrency is also important to avoid breaching the constraint.

Implementations

impl<R, C: Clock> Resource<R, C>

pub fn new(limiter: Limiter<C>, resource: R) -> Self

Creates a new speed-limited resource.

To make the resouce have unlimited speed, set the speed of Limiter to infinity.

pub fn into_inner(self) -> R

Unwraps this value, returns the underlying resource.

pub fn get_ref(&self) -> &R

Gets a reference to the underlying resource.

It is inadvisable to directly operate the underlying resource.

pub fn get_mut(&mut self) -> &mut R

Gets a mutable reference to the underlying resource.

It is inadvisable to directly operate the underlying resource.

pub fn get_pin_ref(self: Pin<&Self>) -> Pin<&R>

Gets a pinned reference to the underlying resource.

It is inadvisable to directly operate the underlying resource.

pub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut R>

Gets a pinned mutable reference to the underlying resource.

It is inadvisable to directly operate the underlying resource.

Trait Implementations

impl<R: AsyncRead, C: Clock> AsyncRead for Resource<R, C>

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

Attempt to read from the AsyncRead into buf.

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

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<R: AsyncRead, C: Clock> AsyncRead for Resource<R, C>

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

Attempts to read from the AsyncRead into buf.

impl<R: AsyncWrite, C: Clock> AsyncWrite for Resource<R, C>

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

Attempt to write bytes from buf into the object.

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

Attempt to write bytes from bufs into the object using vectored IO operations.

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

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

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

Attempt to close the object.

impl<R: AsyncWrite, C: Clock> AsyncWrite for Resource<R, C>

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

Attempt to write bytes from buf into the object.

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

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<()>>

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<'__pin, R, C: Clock> Unpin for Resource<R, C>

where PinnedFieldsOf<__Origin<'__pin, R, C>>: Unpin,