Module markov.common.markov_queue.queue_batch_consumer

Classes

class QueueBatchConsumer (queue_wrapper: PersistAckQueueWrapper[~QUEUE_MESSAGE_TYPE], thread_pool_executor: concurrent.futures.thread.ThreadPoolExecutor, batch_size: int, consume_method: Callable[[Any], bool], batch_timeout: int = None)

Abstract base class for generic types.

A generic type is typically declared by inheriting from this class parameterized with one or more type variables. For example, a generic mapping type might be defined as::

class Mapping(Generic[KT, VT]): def getitem(self, key: KT) -> VT: … # Etc.

This class can then be used as follows::

def lookup_name(mapping: Mapping[KT, VT], key: KT, default: VT) -> VT: try: return mapping[key] except KeyError: return default

Ancestors

• typing.Generic

Methods

def consume(self, batch_size: int = None, block=False)