QueueΒΆ
Is entity based on aioworkers.queue.base.AbstractQueue
The simplest example demonstrating the idea (not intended for use):
class Queue(AbstractQueue):
async def put(self, item):
self._q.append(item)
async def get(self):
return self._q.pop(0)