It'd be really helpful if there were examples of using the futures-based APIs.
I'm currently trying out multiqueue in a Gotham-based webapp and when I try to use the futures::stream::Stream API (specifically into_future), I'm getting ridiculous CPU usage (>15% per receiver). So I assume I must be doing something wrong, hence a desire for example code to double-check myself :)
Hi!
It'd be really helpful if there were examples of using the futures-based APIs.
I'm currently trying out multiqueue in a Gotham-based webapp and when I try to use the
futures::stream::StreamAPI (specifically into_future), I'm getting ridiculous CPU usage (>15% per receiver). So I assume I must be doing something wrong, hence a desire for example code to double-check myself :)