Function txns_progress_frontiers 

fn txns_progress_frontiers<'scope, K, V, T, D, P, C>(
    remap: StreamVec<'scope, T, DataRemapEntry<T>>,
    passthrough: StreamVec<'scope, T, P>,
    name: &str,
    data_id: ShardId,
    until: Antichain<T>,
    unique_id: u64,
) -> (StreamVec<'scope, T, 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,