tokahuke / yaque

Yaque is yet another disk-backed persistent queue for Rust.
Other
81 stars 11 forks source link

Add Recevier::recv_batch_up_to, try_recv_batch_up_to #28

Closed mullr closed 11 months ago

mullr commented 11 months ago

This adds a new batch recv variant, aimed at applications where message processing latency is important but batch processing can still be valuable.

I also fixed up the fuzz tests a bit:

tokahuke commented 11 months ago

Nice! I will review this tomorrow...

tokahuke commented 11 months ago

Approved!