Enum IncomingSection 

pub enum IncomingSection {
    SingleBlock((Option<DXBBlock>, IncomingEndpointContextSectionId)),
    BlockStream((Option<UnboundedReceiver<DXBBlock>>, IncomingEndpointContextSectionId)),
}

Variants

SingleBlock((Option<DXBBlock>, IncomingEndpointContextSectionId))

a single block

BlockStream((Option<UnboundedReceiver<DXBBlock>>, IncomingEndpointContextSectionId))

a stream of blocks the stream is finished when a block has the end_of_block flag set

Implementations

impl IncomingSection

pub async fn next(&mut self) -> Option<DXBBlock>

pub async fn drain(&mut self) -> Vec<DXBBlock>

impl IncomingSection

pub fn get_section_index(&self) -> IncomingSectionIndex

pub fn get_sender(&self) -> Endpoint

pub fn get_section_context_id(&self) -> &IncomingEndpointContextSectionId

Trait Implementations

impl Debug for IncomingSection

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

Formats the value using the given formatter.