Replaced Queue implementation with Coro::PrioChannel