Trait Handler 

pub trait Handler: Send + 'static {
    // Required methods
    fn on_downstream_data(&mut self, io: &mut SessionIo<'_>, data: &[u8]);
    fn on_upstream_connected(&mut self, io: &mut SessionIo<'_>);
    fn on_upstream_data(&mut self, io: &mut SessionIo<'_>, data: &[u8]);
    fn on_downstream_eof(&mut self, io: &mut SessionIo<'_>);
    fn on_upstream_eof(&mut self, io: &mut SessionIo<'_>);
    fn on_upstream_error(&mut self, io: &mut SessionIo<'_>, err: Error);

    // Provided methods
    fn on_connected(&mut self, io: &mut SessionIo<'_>) { ... }
    fn on_downstream_flushed(&mut self, io: &mut SessionIo<'_>) { ... }
    fn on_upstream_flushed(&mut self, io: &mut SessionIo<'_>) { ... }
    fn on_downstream_error(&mut self, io: &mut SessionIo<'_>, err: Error) { ... }
    fn on_shutdown_hint(&mut self, io: &mut SessionIo<'_>) { ... }
    fn on_deadline(&mut self, io: &mut SessionIo<'_>, reason: DeadlineReason) { ... }
}

Per-connection handler. One instance is shared by all sessions of a worker (single-threaded dispatch; per-connection state lives in the session, reached through SessionIo).

Required Methods

fn on_downstream_data(&mut self, io: &mut SessionIo<'_>, data: &[u8])

Bytes arrived from the downstream (client) socket.

fn on_upstream_connected(&mut self, io: &mut SessionIo<'_>)

Upstream connect established.

fn on_upstream_data(&mut self, io: &mut SessionIo<'_>, data: &[u8])

Bytes arrived from the upstream (backend) socket.

fn on_downstream_eof(&mut self, io: &mut SessionIo<'_>)

Downstream EOF (client half-closed).

fn on_upstream_eof(&mut self, io: &mut SessionIo<'_>)

Upstream EOF.

fn on_upstream_error(&mut self, io: &mut SessionIo<'_>, err: Error)

Upstream I/O error.

Provided Methods

fn on_connected(&mut self, io: &mut SessionIo<'_>)

A new downstream connection was accepted.

fn on_downstream_flushed(&mut self, io: &mut SessionIo<'_>)

The queued downstream write batch fully flushed.

fn on_upstream_flushed(&mut self, io: &mut SessionIo<'_>)

The queued upstream write batch fully flushed.

fn on_downstream_error(&mut self, io: &mut SessionIo<'_>, err: Error)

Downstream I/O error (session should close).

fn on_shutdown_hint(&mut self, io: &mut SessionIo<'_>)

Worker is draining (shutdown): finish in-flight work promptly.

fn on_deadline(&mut self, io: &mut SessionIo<'_>, reason: DeadlineReason)

Session deadline expired; reason says which deadline.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors