Function dataflow::render::sources::append_metadata_to_value[][src]

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