pub(crate) fn producer(
    count: u64
) -> Session<SendValue<u64, Wrap<WrapIntStream>>>