Attempt to add with overflow: producer.rs line 234

[DataFrogman]

Describe the bug

I have run into an integer overflow error in producer.rs, it appears that the 'val' created on line 232 should be set to usize rather than determined by the compiler.

Reproduction steps

1. Create a queue with a max size of 25GB
2. Async create producers (max 16 at a time)
3. Push 50,000+ messages per producer
4. When queue length is greater than 300,000 eventually the error will occur

Expected behavior

Integers to be allocated of the maximum necessary size, potentially at usize maximum.

Additional context

No response

[Gsantomaggio]

Can you please provide the program to reproduce the issue?
GitRepo or Gist
Thank you

[DataFrogman]

fn producer_thread(rx: Receiver<Message>, environment: Environment)  -> Result<(), Box<dyn Error + Send + Sync>> {
    let runtime = tokio::runtime::Runtime::new().unwrap();
    let _guard = runtime.enter();
    let producer = match runtime.block_on(environment.producer().batch_delay(Duration::from_secs(1)).batch_size(100).build("test")) {
        Ok(x) => Arc::new(x),
        Err(e) => {
            println!("Producer creation error");
            return Err(e.to_string().into())
        }
    };
    loop {
        let mess = rx.recv()?;
        let temp = producer.clone();
        tokio::spawn(async move {temp.send_with_confirm(mess).await});
    }
}

Here is a function that will cause it. I have an external loop that is using the mpsc channel to feed messages to the producer to send into rabbitmq. Unfortunately after a couple of seconds the threads will start crashing with the error The application panicked (crashed). Message: attempt to add with overflow Location: /home/ubuntu/.cargo/git/checkouts/rabbitmq-stream-rust-client-09c996cc06a727bd/f335c59/src/producer.rs:239