Struct TAsyncBinaryProtocol 

pub struct TAsyncBinaryProtocol<R> { /* private fields */ }

Implementations

impl<R> TAsyncBinaryProtocol<R>

where R: AsyncRead + Unpin + Send,

pub fn new(reader: R) -> Self

Trait Implementations

impl<R> TAsyncInputProtocol for TAsyncBinaryProtocol<R>

where R: AsyncRead + Unpin + Send,

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

Read the beginning of a Thrift message.

async fn read_message_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift message.

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

Read the beginning of a Thrift struct.

async fn read_struct_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift struct.

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

Read the beginning of a Thrift struct field.

async fn read_field_end(&mut self) -> Result<(), ThriftException>

Read the end of a Thrift struct field.

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

Read a bool.

async fn read_bytes(&mut self) -> Result<Bytes, ThriftException>

Read a binary.

async fn read_bytes_vec(&mut self) -> Result<Vec<u8>, ThriftException>

Read a binary, return Vec<u8>

async fn read_uuid(&mut self) -> Result<[u8; 16], ThriftException>

Read a uuid.

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

Read a string.

async fn read_faststr(&mut self) -> Result<FastStr, ThriftException>

Read a string, return FastStr

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

Read a byte.

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

Read a word.

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

Read a 16-bit signed integer.

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

Read a 32-bit signed integer.

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

Read a 64-bit signed integer.

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

Read a 64-bit float.

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

Read the beginning of a list.

async fn read_list_end(&mut self) -> Result<(), ThriftException>

Read the end of a list.

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

Read the beginning of a set.

async fn read_set_end(&mut self) -> Result<(), ThriftException>

Read the end of a set.

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

Read the beginning of a map.

async fn read_map_end(&mut self) -> Result<(), ThriftException>

Read the end of a map.

fn skip( &mut self, field_type: TType, ) -> impl Future<Output = Result<(), ThriftException>> + Send

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

fn skip_till_depth<'life_self, 'async_recursion>( &'life_self mut self, field_type: TType, depth: i8, ) -> Pin<Box<dyn Future<Output = Result<(), ThriftException>> + Send + 'async_recursion>>

where 'life_self: 'async_recursion,

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