Struct toku_connection::ReaderWriter

pub struct ReaderWriter {
    pub reader: SplitStream<Framed<TcpStream, Codec>>,
    // some fields omitted
}

Fields

reader: SplitStream<Framed<TcpStream, Codec>>

Implementations

impl ReaderWriter

pub fn new(
    tcp_stream: TcpStream,
    max_payload_size: ByteSize,
    send_go_away: bool
) -> Self

Create a new ReaderWriter that can read and write frames to a tcp socket.

Arguments

• tcp_stream - raw tcp socket
• max_payload_size - the maximum bytes a frame payload can be
• send_go_away - whether or not to send a go away when the connection closes

pub async fn write<F: Into<TokuFrame>>(
    self,
    frame: F
) -> Result<Self, TokuError>

Tries to write a TokuFrame to the socket. Returns an error if the socket has closed.

pub fn split(self) -> (SplitStream<Framed<TcpStream, Codec>>, Writer)

Split this ReaderWriter, returning the Reader and Writer parts.

pub async fn close(self, error: Option<&Error>)

Gracefully closes the socket. Optionally sends a GoAway frame before closing.