Source code for minos.networks.brokers.subscribers.queued.queues.memory

from __future__ import (
    annotations,
)

import logging

from ....collections import (
    InMemoryBrokerQueue,
)
from .abc import (
    BrokerSubscriberQueue,
    BrokerSubscriberQueueBuilder,
)

logger = logging.getLogger(__name__)


[docs]class InMemoryBrokerSubscriberQueue(InMemoryBrokerQueue, BrokerSubscriberQueue):
    """In Memory Broker Subscriber Queue class."""


[docs]class InMemoryBrokerSubscriberQueueBuilder(BrokerSubscriberQueueBuilder[InMemoryBrokerSubscriberQueue]):
    """In Memory Broker Subscriber Queue Builder class."""


InMemoryBrokerSubscriberQueue.set_builder(InMemoryBrokerSubscriberQueueBuilder)