search

schets / multiqueue

A fast mpmc queue with broadcast capabilities
MIT License
201 stars 29 forks source link

Futures stream/sink #1

Closed schets closed 7 years ago

schets commented 7 years ago

This should have futures stream/sink support so it can be used with Tokio. I really hope that it can be done in a way that doesn't require a lot of atomics and no allocations, but I still have to fully wrap my head around the Task setup.

schets commented 7 years ago

It's in, and is passing the mpsc tests already. More tests to come