Trait EnvelopeCollection 

pub trait EnvelopeCollection<'env>: MaybeSend + MaybeSync {
    // Required methods
    fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>;
    fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>;
    fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>;
    fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>;
    fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>;
    fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>;
    fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>;
    fn welcome_messages(
        &self,
    ) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>;
    fn len(&self) -> usize;
    fn is_empty(&self) -> bool;
    fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>
       where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>,
             for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>,
             Self: Sized;
}

A Generic Higher-Level Collection of Envelopes

Required Methods

fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>

Get the topic for an envelope

fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>

get the cursors for each envelope

fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>

Get the payload for an envelope

fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>

get orphans for these envelopes

fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>

get the data field for each envelope as a sha256 hash

fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>

Build the ClientEnvelope

fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>

Try to get a group message from this Envelope

fn welcome_messages(&self) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>

Try to get a welcome message

fn len(&self) -> usize

Length of the Collection

fn is_empty(&self) -> bool

Whether the Collection of Envelopes is empty

fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>

where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>, for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>, Self: Sized,

run a sequenced extraction on the envelopes in this collection

Implementations on Foreign Types

impl EnvelopeCollection<'_> for SubscribeGroupMessagesRequest

fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>

fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>

fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>

fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>

fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>

where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>, for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>, Self: Sized,

fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>

fn welcome_messages(&self) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>

fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>

impl EnvelopeCollection<'_> for SubscribeWelcomeMessagesRequest

fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>

fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>

fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>

fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>

fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>

where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>, for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>, Self: Sized,

fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>

fn welcome_messages(&self) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>

fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>

impl EnvelopeCollection<'_> for SubscribeEnvelopesResponse

fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>

fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>

fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>

fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>

fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>

where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>, Self: Clone + Sized, for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>,

fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>

fn welcome_messages(&self) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>

fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>

impl<'env, T> EnvelopeCollection<'env> for Vec<T>

where T: ProtocolEnvelope<'env> + Debug + MaybeSend + MaybeSync,

fn topics(&self) -> Result<Vec<Topic>, EnvelopeError>

fn cursors(&self) -> Result<Vec<Cursor>, EnvelopeError>

fn orphans(&self) -> Result<Vec<OrphanedEnvelope>, EnvelopeError>

fn payloads(&self) -> Result<Vec<Payload>, EnvelopeError>

fn sha256_hashes(&self) -> Result<Vec<Vec<u8>>, EnvelopeError>

fn client_envelopes(&self) -> Result<Vec<ClientEnvelope>, EnvelopeError>

fn group_messages(&self) -> Result<Vec<Option<GroupMessage>>, EnvelopeError>

fn welcome_messages(&self) -> Result<Vec<Option<WelcomeMessage>>, EnvelopeError>

fn len(&self) -> usize

fn is_empty(&self) -> bool

fn consume<E>(self) -> Result<Vec<<E as Extractor>::Output>, EnvelopeError>

where for<'a> E: Default + Extractor + EnvelopeVisitor<'a>, for<'a> EnvelopeError: From<<E as EnvelopeVisitor<'a>>::Error>, Self: Sized,

Implementors