soup/wove
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Loosen requiremenst on IoImpl

Browse source
This commit is contained in:
soup 2024-10-22 23:58:18 -04:00
parent 2f493c724f
commit 520f3fd949
No known key found for this signature in database
2 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/io_impl/mod.rs
View file

@ -1,7 +1,4 @@
use crate::{ use crate::aliases::IoResult;
aliases::IoResult,
io::{AsyncReadLoan, AsyncWriteLoan},
};
use std::{future::Future, net::SocketAddr, time::Duration}; use std::{future::Future, net::SocketAddr, time::Duration};
#[cfg(feature = "io_uring")] #[cfg(feature = "io_uring")]
@ -26,7 +23,7 @@ pub trait IoImpl {
listener: &mut Self::TcpListener, listener: &mut Self::TcpListener,
) -> impl Future<Output = IoResult<Self::Incoming>>; ) -> impl Future<Output = IoResult<Self::Incoming>>;
type TcpStream: AsyncReadLoan + AsyncWriteLoan; type TcpStream;
fn tcp_connect( fn tcp_connect(
&self, &self,
socket: SocketAddr, socket: SocketAddr,

10
src/net.rs
View file

@ -18,13 +18,19 @@ impl<I: IoImpl> TcpStream<I> {
} }
} }
impl<I: IoImpl> AsyncReadLoan for TcpStream<I> { impl<I: IoImpl> AsyncReadLoan for TcpStream<I>
where
I::TcpStream: AsyncReadLoan,
{
async fn read<B: BufferMut>(&mut self, buf: B) -> (B, IoResult<usize>) { async fn read<B: BufferMut>(&mut self, buf: B) -> (B, IoResult<usize>) {
self.0.read(buf).await self.0.read(buf).await
} }
} }
impl<I: IoImpl> AsyncWriteLoan for TcpStream<I> { impl<I: IoImpl> AsyncWriteLoan for TcpStream<I>
where
I::TcpStream: AsyncWriteLoan,
{
async fn write<B: Buffer>(&mut self, buf: B) -> (B, IoResult<usize>) { async fn write<B: Buffer>(&mut self, buf: B) -> (B, IoResult<usize>) {
self.0.write(buf).await self.0.write(buf).await
} }