Function txns_progress_frontiers 

fn txns_progress_frontiers<K, V, T, D, P, C, G>(
    remap: StreamVec<G, DataRemapEntry<T>>,
    passthrough: StreamVec<G, P>,
    name: &str,
    data_id: ShardId,
    until: Antichain<T>,
    unique_id: u64,
) -> (StreamVec<G, P>, PressOnDropButton)
where
    K: Debug + Codec,
    V: Debug + Codec,
    T: Timestamp + Lattice + TotalOrder + StepForward + Codec64,
    D: Clone + 'static + Monoid + Codec64 + Send + Sync,
    P: Debug + Clone + 'static,
    C: TxnsCodec,
    G: Scope<Timestamp = T>,