Module stream

Module stream 

Source

Structs§

FlattenedStream
OrderedStream
TryExtractorStream

Enums§

OrderedStreamError

Functions§

flattened
Wrap a TryStream<T> whos items, TryStream::::Ok, implement Paged. functionally, this means a struct wrapping a Vec will return the inner Vec instead of the struct
ordered
Wrap a TryStream<T> who’s items are Envelope’s such that it orders the envelopes according to XIP-49 Cross-Originator Message Ordering. If an envelope cannot yet be processed due to missing required dependencies, the streamed message will be put into a persistent “icebox” until the required dependency is streamed. This stream implementation will not attempt to do any further dependency resolution with ResolveDependencies. there is an implicit assumption that if an item in the stream is required for processing, it will at some point be made available in the stream. This stream instead uses the NoopResolver
try_extractor
Wrap a TryStream<T> such that it converts its ‘item’ to T