Function join_by_timestamp

pub fn join_by_timestamp<D1, D2, T, G>(
    in_stream1: &Stream<G, D1>,
    in_stream2: &Stream<G, D2>,
) -> Stream<G, (D1, D2)>
where
    D1: Data,
    D2: Data,
    G: Scope<Timestamp = T>,