Function dataflow::render::sources::seal_and_await

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, 

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.