Function hydro_std::request_response::join_responses
source ยท 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>
Expand description
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.