Closed marmistrz closed 2 years ago
This was a combination of two things:
Batch<T>
share the pending/unsent requests queues. This should be documented. I'll open a documentation PR in a while
- the fact that cloned instances of
Batch<T>
share the pending/unsent requests queues. This should be documented. I'll open a documentation PR in a while
I never experienced parsing error, but With a simple code like this:
let mut subscription = web3s.eth_subscribe().subscribe_logs(filter.clone()).await?;
let test = subscription.next().await;
println!("{:?}", test);
I got None right now, instead of waiting for the filter requirtments to met. And if I try to loop and using web3 then I get this code easily also.
Transport("Cannot send request. Internal task finished.")
Please open a separate issue for this.
For the example, I'm using the public API key from Alchemy for testing rate limits, see https://docs.alchemy.com/alchemy/documentation/throughput
Example code:
Running this with
cargo run
will cause abnormal request grouping:and further panics such as:
or
This only happens for batch transports