Struct condure::connection::ServerStreamConnection

pub struct ServerStreamConnection { /* fields omitted */ }

Implementations

impl ServerStreamConnection

pub fn new(
    now: Instant,
    peer_addr: Option<SocketAddr>,
    buffers: &Arc<Reusable<RingBuffer>>,
    trackers: &Arc<Reusable<MessageTracker>>,
    timeout: Duration
) -> Self

pub fn state(&self) -> ServerState

pub fn to_addr(&self) -> Option<&[u8]>

pub fn next_out_seq(&mut self) -> u32

pub fn start(&mut self, id: &str)

pub fn set_sock_readable(&mut self)

pub fn process<S, Z>(
    &mut self,
    now: Instant,
    instance: &str,
    sock: &mut S,
    zsender: &mut Z,
    packet_buf: &mut [u8],
    tmp_buf: &mut [u8]
) -> Result<Want, ServerError> where
    S: Read + Write + WriteVectored,
    Z: ZhttpSender, 

pub fn apply_zhttp_response(
    &mut self,
    now: Instant,
    zresp: &Response,
    seq: Option<u32>
) -> Result<(), ServerError>