Struct thrift::protocol::TCompactInputProtocol

pub struct TCompactInputProtocol<T> where
    T: TReadTransport,  { /* fields omitted */ }

Read messages encoded in the Thrift compact protocol.

Examples

Create and use a TCompactInputProtocol.

use thrift::protocol::{TCompactInputProtocol, TInputProtocol};
use thrift::transport::TTcpChannel;

let mut channel = TTcpChannel::new();
channel.open("localhost:9090").unwrap();

let mut protocol = TCompactInputProtocol::new(channel);

let recvd_bool = protocol.read_bool().unwrap();
let recvd_string = protocol.read_string().unwrap();

Methods

impl<T> TCompactInputProtocol<T> where
    T: TReadTransport, 

pub fn new(transport: T) -> TCompactInputProtocol<T>

Create a TCompactInputProtocol that reads bytes from transport.

Trait Implementations

impl<T> TInputProtocol for TCompactInputProtocol<T> where
    T: TReadTransport, 

fn read_message_begin(&mut self) -> Result<TMessageIdentifier>

Read the beginning of a Thrift message.

fn read_message_end(&mut self) -> Result<()>

Read the end of a Thrift message.

fn read_struct_begin(&mut self) -> Result<Option<TStructIdentifier>>

Read the beginning of a Thrift struct.

fn read_struct_end(&mut self) -> Result<()>

Read the end of a Thrift struct.

fn read_field_begin(&mut self) -> Result<TFieldIdentifier>

Read the beginning of a Thrift struct field.

fn read_field_end(&mut self) -> Result<()>

Read the end of a Thrift struct field.

fn read_bool(&mut self) -> Result<bool>

Read a bool.

fn read_bytes(&mut self) -> Result<Vec<u8>>

Read a fixed-length byte array.

fn read_i8(&mut self) -> Result<i8>

Read a word.

fn read_i16(&mut self) -> Result<i16>

Read a 16-bit signed integer.

fn read_i32(&mut self) -> Result<i32>

Read a 32-bit signed integer.

fn read_i64(&mut self) -> Result<i64>

Read a 64-bit signed integer.

fn read_double(&mut self) -> Result<f64>

Read a 64-bit float.

fn read_string(&mut self) -> Result<String>

Read a fixed-length string (not null terminated).

fn read_list_begin(&mut self) -> Result<TListIdentifier>

Read the beginning of a list.

fn read_list_end(&mut self) -> Result<()>

Read the end of a list.

fn read_set_begin(&mut self) -> Result<TSetIdentifier>

Read the beginning of a set.

fn read_set_end(&mut self) -> Result<()>

Read the end of a set.

fn read_map_begin(&mut self) -> Result<TMapIdentifier>

Read the beginning of a map.

fn read_map_end(&mut self) -> Result<()>

Read the end of a map.

fn read_byte(&mut self) -> Result<u8>

Read an unsigned byte.

fn skip(&mut self, field_type: TType) -> Result<()>

Skip a field with type field_type recursively until the default maximum skip depth is reached.

fn skip_till_depth(&mut self, field_type: TType, depth: i8) -> Result<()>

Skip a field with type field_type recursively up to depth levels.

impl<T: Debug> Debug for TCompactInputProtocol<T> where
    T: TReadTransport, 

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

Formats the value using the given formatter.

impl<T> Seek for TCompactInputProtocol<T> where
    T: Seek + TReadTransport, 

fn seek(&mut self, pos: SeekFrom) -> Result<u64>

Seek to an offset, in bytes, in a stream.

fn stream_len(&mut self) -> Result<u64, Error>

🔬 This is a nightly-only experimental API. (seek_convenience)

Returns the length of this stream (in bytes).

fn stream_position(&mut self) -> Result<u64, Error>

🔬 This is a nightly-only experimental API. (seek_convenience)

Returns the current seek position from the start of the stream.