Struct ScannedStream 

pub struct ScannedStream<'a, St: ?Sized, RW: Read + Write> { /* private fields */ }

A wrapper stream holding byte stream. This sends the inner stream to clamav to scan it while passes it through to the consumer.

Implementations

impl<'a, St, RW, E> ScannedStream<'a, St, RW>

where St: Stream<Item = Result<Bytes, E>> + Unpin + ?Sized, RW: Read + Write, E: StdError,

pub fn new(input: &'a mut St, inner: RW) -> Self

Create a new ScannedStream

pub fn tcp( input: &'a mut St, addr: impl ToSocketAddrs, ) -> Result<ScannedStream<'a, St, TcpStream>, Error>

Create a new ScannedStream connecting to clamav server with tcp socket.

pub fn socket( input: &'a mut St, path: impl AsRef<Path>, ) -> Result<ScannedStream<'a, St, UnixStream>, Error>

Create a new ScannedStream connecting to clamav server with unix socket.

Trait Implementations

impl<'a, St, RW, E> Stream for ScannedStream<'a, St, RW>

where St: Stream<Item = Result<Bytes, E>> + Unpin + ?Sized, RW: Read + Write, E: StdError + Send + Sync + 'static,

type Item = Result<Bytes, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'pin, 'a, St: ?Sized, RW: Read + Write> Unpin for ScannedStream<'a, St, RW>

where PinnedFieldsOf<__ScannedStream<'pin, 'a, St, RW>>: Unpin,