pub fn ordered<S, Store, T>(
s: S,
cursor_store: Store,
initial_topic_cursor: TopicCursor,
) -> OrderedStream<S, Store, T>Expand description
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