Function wrap_stream::consumer

pub(crate) fn consumer(
) -> Session<ReceiveChannel<SendValue<u64, Wrap<WrapIntStream>>, End>>