Struct TestIoService 

pub struct TestIoService {
    pub read: Arc<Mutex<Vec<u8>>>,
    pub write: Arc<Vec<u8>>,
}

A service you can conveniently use to validate layers that interact with AsyncReadExt and AsyncWriteExt

Fields

read: Arc<Mutex<Vec<u8>>>

write: Arc<Vec<u8>>

Implementations

impl TestIoService

pub fn new(write: Vec<u8>) -> Self

Trait Implementations

impl Clone for TestIoService

fn clone(&self) -> TestIoService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TestIoService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Reader, Writer> Service<(Reader, Writer)> for TestIoService

where Reader: AsyncReadExt + Send + Unpin + 'static, Writer: AsyncWriteExt + Send + Unpin + 'static,

type Response = ()

Responses given by the service.

type Error = ()

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<TestIoService as Service<(Reader, Writer)>>::Response, <TestIoService as Service<(Reader, Writer)>>::Error>> + Send>>

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, (read, write): (Reader, Writer)) -> Self::Future

Process the request and return the response asynchronously.