hyperion.adapters.queue.memory

hyperion.adapters.queue.memory

In-memory :class:Queue adapter (lite -- not persistent).

InMemoryQueue

InMemoryQueue()

Bases: Queue

Source code in hyperion/adapters/queue/memory.py

def __init__(self) -> None:
    super().__init__()
    self._messages: list[Message] = []

delete

delete(receipt_handle)

Delete the message identified by receipt_handle.

Matches on the receipt_handle field assigned by :meth:send. Deleting an unknown handle is a no-op.

Source code in hyperion/adapters/queue/memory.py

def delete(self, receipt_handle: str) -> None:
    """Delete the message identified by *receipt_handle*.

    Matches on the ``receipt_handle`` field assigned by :meth:`send`.
    Deleting an unknown handle is a no-op.
    """
    for message in self._messages:
        if message.receipt_handle == receipt_handle:
            self._messages.remove(message)
            break