Trait TInputProtocol

Source

pub trait TInputProtocol {
Show 23 methods    // Required methods
    fn read_message_begin(&mut self) -> Result<TMessageIdentifier>;
    fn read_message_end(&mut self) -> Result<()>;
    fn read_struct_begin(&mut self) -> Result<Option<TStructIdentifier>>;
    fn read_struct_end(&mut self) -> Result<()>;
    fn read_field_begin(&mut self) -> Result<TFieldIdentifier>;
    fn read_field_end(&mut self) -> Result<()>;
    fn read_bool(&mut self) -> Result<bool>;
    fn read_bytes(&mut self) -> Result<Vec<u8>>;
    fn read_i8(&mut self) -> Result<i8>;
    fn read_i16(&mut self) -> Result<i16>;
    fn read_i32(&mut self) -> Result<i32>;
    fn read_i64(&mut self) -> Result<i64>;
    fn read_double(&mut self) -> Result<f64>;
    fn read_string(&mut self) -> Result<String>;
    fn read_list_begin(&mut self) -> Result<TListIdentifier>;
    fn read_list_end(&mut self) -> Result<()>;
    fn read_set_begin(&mut self) -> Result<TSetIdentifier>;
    fn read_set_end(&mut self) -> Result<()>;
    fn read_map_begin(&mut self) -> Result<TMapIdentifier>;
    fn read_map_end(&mut self) -> Result<()>;
    fn read_byte(&mut self) -> Result<u8>;

    // Provided methods
    fn skip(&mut self, field_type: TType) -> Result<()> { ... }
    fn skip_till_depth(
        &mut self,
        field_type: TType,
        remaining_depth: i8,
    ) -> Result<()> { ... }
}

Expand description

Contains the minimum set of functions necessary to read a Thrift service call, primitive or container from the wire.

This trait does not deal with higher-level types like structs or exceptions

only with primitives, message or container boundaries. Once read the data is returned either as an identifier (for example TMessageIdentifier) or as the primitive itself.

All methods return a rift::Result. If a method returns an Err the underlying transport or protocol should be considered suspect, and the channel should be terminated.

§Examples

Using a TInputProtocol

use std::cell::RefCell;
use std::rc::Rc;

use rift::protocol::{TBinaryInputProtocol, TInputProtocol, TType};
use rift::transport::{TTcpTransport, TTransport};

let mut transport = TTcpTransport::new();
transport.open("127.0.0.1:9090");
let transport = Rc::new(RefCell::new(Box::new(transport) as Box<TTransport>));

let mut i_prot = TBinaryInputProtocol::new(true, transport.clone());

let field_identifier = i_prot.read_field_begin().unwrap();
let field_contents = i_prot.read_string().unwrap();
let field_end = i_prot.read_field_end().unwrap();