use hyper::rt::{Read, ReadBufCursor, Write};
use std::io;
use std::pin::Pin;
use std::task::{Context, Poll};
use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
use tokio::sync::OwnedSemaphorePermit;
pub(crate) struct IoWithPermit<T> {
io: T,
_permit: OwnedSemaphorePermit,
}
impl<T> IoWithPermit<T> {
#[inline]
pub fn new(io: T, _permit: OwnedSemaphorePermit) -> Self {
Self { io, _permit }
}
}
impl<T: AsyncRead + Unpin> Read for IoWithPermit<T> {
fn poll_read(
mut self: Pin<&mut Self>,
context: &mut Context,
mut buf: ReadBufCursor,
) -> Poll<io::Result<()>> {
let len = unsafe {
let mut dest = ReadBuf::uninit(buf.as_mut());
let Poll::Ready(_) = Pin::new(&mut self.io).poll_read(context, &mut dest)? else {
return Poll::Pending;
};
dest.filled().len()
};
unsafe { buf.advance(len) };
Poll::Ready(Ok(()))
}
}
impl<T: AsyncWrite + Unpin> Write for IoWithPermit<T> {
fn poll_write(
mut self: Pin<&mut Self>,
context: &mut Context<'_>,
buf: &[u8],
) -> Poll<io::Result<usize>> {
Pin::new(&mut self.io).poll_write(context, buf)
}
fn poll_flush(mut self: Pin<&mut Self>, context: &mut Context<'_>) -> Poll<io::Result<()>> {
Pin::new(&mut self.io).poll_flush(context)
}
fn poll_shutdown(mut self: Pin<&mut Self>, context: &mut Context<'_>) -> Poll<io::Result<()>> {
Pin::new(&mut self.io).poll_shutdown(context)
}
fn is_write_vectored(&self) -> bool {
self.io.is_write_vectored()
}
fn poll_write_vectored(
mut self: Pin<&mut Self>,
context: &mut Context<'_>,
bufs: &[io::IoSlice<'_>],
) -> Poll<io::Result<usize>> {
Pin::new(&mut self.io).poll_write_vectored(context, bufs)
}
}