Skip to main content

read_rpc_type

Function read_rpc_type 

Source
pub async fn read_rpc_type(
    recv: &mut RecvStream,
) -> Result<RpcType, PyroLinkError>
Expand description

Read the RPC type byte from the start of a new QUIC stream.

This is the first byte sent by the client on every new bidirectional stream. It tells the server which Arrow Flight RPC this stream carries.

§Errors

Returns PyroLinkError if the stream ends before a byte is available or if the byte value is not a known RPC type.