Skip to main content

poll_write_limited

tor_async_utils::global_rate_limit::writer

Function poll_write_limited 

Source 
pub(super) fn poll_write_limited<W: AsyncWrite>(
    inner: Pin<&mut W>,
    state: &mut DirectionState,
    cx: &mut Context<'_>,
    buf: &[u8],
) -> Poll<Result<usize, Error>>
Expand description

Helper: Rate-limited AsyncWrite::poll_write of inner using the given read direction state. This is used by multiple object hence why in a write helper.