fn append_metadata_to_value<G>( results: Stream<G, DecodeResult>) -> Stream<G, KV> where G: Scope<Timestamp = Timestamp>,