Struct Handler

Source
pub struct Handler { /* private fields */ }
Expand description

The standard, blocking TCP I/O handler.

This handler makes use of the standard, blocking std::net::TcpStream to read from and write to TCP streams.

Implementations§

Source§

impl Handler

Source

pub fn new(host: impl AsRef<str>, port: u16) -> Result<Self>

Builds a new handler.

This function does perform I/O, as it connects to the TCP stream matching the given hostname and port.

Source

pub fn read(&mut self, flow: impl AsMut<State>) -> Result<()>

Processes the read::Io::Read request.

This function reads synchronously a chunk of bytes from the inner TCP stream to its inner state read buffer, then set how many bytes have been read.

Source

pub fn write(&mut self, flow: impl AsMut<State>) -> Result<()>

Processes the write::Io::Write request.

This function writes synchronously bytes to the inner TCP stream from its inner state write buffer, then set how many bytes have been written.

Trait Implementations§

Source§

impl Debug for Handler

Source§

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

Formats the value using the given formatter. Read more
Source§

impl From<TcpStream> for Handler

Source§

fn from(stream: TcpStream) -> Self

Converts to this type from the input type.
Source§

impl TryFrom<SocketAddr> for Handler

Source§

type Error = Error

The type returned in the event of a conversion error.
Source§

fn try_from(addr: SocketAddr) -> Result<Self>

Performs the conversion.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more