Skip to main content

allow a single producer to provide the same payload to multiple consumers simultaniously

Project description


PyPI version Python Versions License: MIT


MultisubscriberQueue allows a single producer to provide the same payload to multiple consumers simultaniously. An asyncio.Queue is created for each consumer and each call to MultisubscriberQueue.put() iterates over each asyncio.Queue and puts the payload on each queue.

Please see for a simple example.

Change Log

[0.3.1] - 2021-12-21

  • Change build system from setuptools to poetry

[0.3.0] - 2021-11-08

  • Add type hints and type validation with mypy
  • Replace _QueueContext object with @contextmanager on MultisubscriberQueue.queue()

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

asyncio-multisubscriber-queue-0.3.1.tar.gz (3.3 kB view hashes)

Uploaded source

Built Distribution

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Huawei Huawei PSF Sponsor Microsoft Microsoft PSF Sponsor NVIDIA NVIDIA PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page