Function hydro_std::request_response::join_responses

pub fn join_responses<'a, K: Clone + Eq + Hash, M: Clone, V: Clone, L: Location<'a> + NoTick>(
    tick: &Tick<L>,
    responses: Stream<(K, V), Atomic<L>, Unbounded, NoOrder>,
    metadata: Stream<(K, M), Tick<L>, Bounded, NoOrder>,
) -> Stream<(K, (M, V)), Atomic<L>, Unbounded, NoOrder>

Given an incoming stream of request-response responses, joins with metadata generated at request time that is stored in-memory.

The metadata must be generated in the same or a previous tick than the response, typically at request time. Only one response element should be produced with a given key, same for the metadata stream.