Struct toku_connection::Connection

pub struct Connection<H: Handler> { /* fields omitted */ }

Implementations

impl<H: Handler> Connection<H>

pub fn spawn_from_address(
    address: SocketAddr,
    handler: H,
    handshake_deadline: Instant,
    ready_tx: Option<Sender<&'static str>>
) -> Self

Spawn a new Connection that runs in a separate task. Returns a handle for sending to the Connection.

Arguments

• tcp_stream - the tcp socket
• handler - implements client or server specific logic
• handshake_deadline - how long until we fail due to handshake not completing
• ready_tx - a sender used to notify that the connection is ready for requests

pub fn spawn(
    tcp_stream: TcpStream,
    handler: H,
    handshake_deadline: Instant,
    ready_tx: Option<Sender<&'static str>>
) -> Self

Spawn a new Connection that runs in a separate task. Returns a handle for sending to the Connection.

Arguments

• tcp_stream - the tcp socket
• handler - implements client or server specific logic
• handshake_deadline - how long until we fail due to handshake not completing
• ready_tx - a sender used to notify that the connection is ready for requests

pub fn send(&self, event: H::InternalEvent) -> Result<(), Error>

pub fn close(&self) -> Result<(), Error>

pub fn is_closed(&self) -> bool

Trait Implementations

impl<H: Debug + Handler> Debug for Connection<H> where
    H::InternalEvent: Debug, 

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

Formats the value using the given formatter.