Function dataflow::render::sources::seal_and_await [−][src]
fn seal_and_await<G, D1, D2, K1, V1, K2, V2>(
stream: &Stream<G, (D1, Timestamp, Diff)>,
bindings_stream: &Stream<G, (D2, Timestamp, Diff)>,
write: StreamWriteHandle<K1, V1>,
bindings_write: StreamWriteHandle<K2, V2>,
source_id: &GlobalId,
source_name: &str,
storage_state: &mut StorageState,
needed_tokens: &mut Vec<Rc<dyn Any>>
) -> Stream<G, (D1, Timestamp, Diff)> where
G: Scope<Timestamp = Timestamp>,
D1: Data,
D2: Data,
K1: Codec + Data,
V1: Codec + Data,
K2: Codec + Data,
V2: Codec + Data,
Expand description
Seals both the main stream and the stream of timestamp bindings, allows compaction on underlying persistent streams, and awaits the seal frontier before passing on updates.