Struct thrust::reactor::FramedTransport

pub struct FramedTransport {
    // some fields omitted
}

Wrap a TcpStream to handle reading and writing frames. Frames are simply some encoded thrift protocol byte buffer preceeded by a 32-bit unsigned length.

Methods

impl FramedTransport

fn new() -> FramedTransport

fn read<S>(&mut self, socket: &mut S) -> ThrustResult<Option<Vec<u8>>> where S: TryRead + TryWrite