Struct adnl::AdnlReceiver

pub struct AdnlReceiver { /* private fields */ }

Low-level incoming datagram processor

Implementations

impl AdnlReceiver

pub fn new(aes_params: &AdnlAesParams) -> Self

Create receiver with given session parameters

pub async fn receive<R: AsyncReadExt + Unpin, C: AsyncWriteExt + Unpin, const BUFFER: usize>( &mut self, transport: &mut R, consumer: &mut C ) -> Result<(), AdnlError>

Receive datagram from transport. Received parts of the decrypted buffer will be sent to consumer, which usually can be just Vec. Note that data can be processed before this function will return, but in case of AdnlError::IntegrityError you must assume that the data was tampered.

You can adjust BUFFER according to your memory requirements. Recommended size is 8192 bytes.