sqlalchemy.util.queue.AsyncAdaptedQueue

class documentation

class AsyncAdaptedQueue(QueueCommon[_T]): (source)

Known subclasses: sqlalchemy.util.queue.FallbackAsyncAdaptedQueue

View In Hierarchy

Undocumented

Static Method await_ Undocumented
Method __init__ Undocumented
Method empty Undocumented
Method full Undocumented
Method get Undocumented
Method get_nowait Undocumented
Method put Undocumented
Method put_nowait Undocumented
Method qsize Undocumented
Instance Variable maxsize Undocumented
Instance Variable use_lifo Undocumented
Property _queue Undocumented
@staticmethod
def await_(coroutine: Awaitable[Any]) -> _T: (source)

Undocumented

def __init__(self, maxsize: int = 0, use_lifo: bool = False): (source)
overrides sqlalchemy.util.queue.QueueCommon.__init__

Undocumented

def empty(self) -> bool: (source)
overrides sqlalchemy.util.queue.QueueCommon.empty

Undocumented

def full(self): (source)
overrides sqlalchemy.util.queue.QueueCommon.full

Undocumented

def get(self, block: bool = True, timeout: Optional[float] = None) -> _T: (source)
overrides sqlalchemy.util.queue.QueueCommon.get

Undocumented

def get_nowait(self) -> _T: (source)
overrides sqlalchemy.util.queue.QueueCommon.get_nowait

Undocumented

def put(self, item: _T, block: bool = True, timeout: Optional[float] = None): (source)
overrides sqlalchemy.util.queue.QueueCommon.put

Undocumented

def put_nowait(self, item: _T): (source)
overrides sqlalchemy.util.queue.QueueCommon.put_nowait

Undocumented

def qsize(self): (source)
overrides sqlalchemy.util.queue.QueueCommon.qsize

Undocumented

maxsize = (source)
overrides sqlalchemy.util.queue.QueueCommon.maxsize

Undocumented

use_lifo = (source)
overrides sqlalchemy.util.queue.QueueCommon.use_lifo

Undocumented

@memoized_property
_queue: asyncio.Queue[_T] = (source)

Undocumented