asyncio-multisubscriber-queue

Name	asyncio-multisubscriber-queue JSON
Version	0.4.1 JSON
	download
home_page	https://github.com/smithk86/asyncio-multisubscriber-queue
Summary	Allow a single producer to provide the same payload to multiple consumers simultaneously
upload_time	2022-12-02 22:52:04
maintainer
docs_url	None
author	Kyle Smith
requires_python	>=3.10,<4
license	MIT
keywords
VCS
bugtrack_url
requirements	No requirements were recorded.
Travis-CI	No Travis.
coveralls test coverage	No coveralls.

            # asyncio-multisubscriber-queue

[![PyPI version](https://img.shields.io/pypi/v/asyncio-multisubscriber-queue)](https://pypi.org/project/asyncio-multisubscriber-queue/)
[![Python Versions](https://img.shields.io/pypi/pyversions/asyncio-multisubscriber-queue)](https://pypi.org/project/asyncio-multisubscriber-queue/)
[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)
[![](https://github.com/smithk86/asyncio-multisubscriber-queue/workflows/pytest/badge.svg)](https://github.com/smithk86/asyncio-multisubscriber-queue/actions?query=workflow%3Apytest)
[![Code style: black](https://img.shields.io/badge/code%20style-black-000000.svg)](https://github.com/psf/black)

## Usage

MultisubscriberQueue allows a single producer to provide the same payload to multiple consumers simultaneously. 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 [example.py](https://github.com/smithk86/asyncio-multisubscriber-queue/blob/master/example.py) for a simple example.

            

Raw data

            {
    "_id": null,
    "home_page": "https://github.com/smithk86/asyncio-multisubscriber-queue",
    "name": "asyncio-multisubscriber-queue",
    "maintainer": "",
    "docs_url": null,
    "requires_python": ">=3.10,<4",
    "maintainer_email": "",
    "keywords": "",
    "author": "Kyle Smith",
    "author_email": "smithk86@smc3.com",
    "download_url": "https://files.pythonhosted.org/packages/dc/05/f9bd03c03def2332f4fd555586f6120786147fca95a745e2d939027e007d/asyncio_multisubscriber_queue-0.4.1.tar.gz",
    "platform": null,
    "description": "# asyncio-multisubscriber-queue\n\n[![PyPI version](https://img.shields.io/pypi/v/asyncio-multisubscriber-queue)](https://pypi.org/project/asyncio-multisubscriber-queue/)\n[![Python Versions](https://img.shields.io/pypi/pyversions/asyncio-multisubscriber-queue)](https://pypi.org/project/asyncio-multisubscriber-queue/)\n[![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://opensource.org/licenses/MIT)\n[![](https://github.com/smithk86/asyncio-multisubscriber-queue/workflows/pytest/badge.svg)](https://github.com/smithk86/asyncio-multisubscriber-queue/actions?query=workflow%3Apytest)\n[![Code style: black](https://img.shields.io/badge/code%20style-black-000000.svg)](https://github.com/psf/black)\n\n## Usage\n\nMultisubscriberQueue allows a single producer to provide the same payload to multiple consumers simultaneously. 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.\n\nPlease see [example.py](https://github.com/smithk86/asyncio-multisubscriber-queue/blob/master/example.py) for a simple example.\n",
    "bugtrack_url": null,
    "license": "MIT",
    "summary": "Allow a single producer to provide the same payload to multiple consumers simultaneously",
    "version": "0.4.1",
    "split_keywords": [],
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "md5": "fda53f1358531f012e2842a941ed4890",
                "sha256": "01820123cf152b694745d5ac7bf6a05068d9bb98d7a7b6487afcda962f5496a0"
            },
            "downloads": -1,
            "filename": "asyncio_multisubscriber_queue-0.4.1-py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "fda53f1358531f012e2842a941ed4890",
            "packagetype": "bdist_wheel",
            "python_version": "py3",
            "requires_python": ">=3.10,<4",
            "size": 4547,
            "upload_time": "2022-12-02T22:52:03",
            "upload_time_iso_8601": "2022-12-02T22:52:03.175978Z",
            "url": "https://files.pythonhosted.org/packages/01/77/b73dbda4864b774a45038a16a9449e6457fc9ab9909489963ff4156dce5b/asyncio_multisubscriber_queue-0.4.1-py3-none-any.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": "",
            "digests": {
                "md5": "684c2427f46e9360e673b1fa27210911",
                "sha256": "e414fb7374ebb13bb1689995c308b8b1cc520a0d60b212dd0e05a6e98b6ae723"
            },
            "downloads": -1,
            "filename": "asyncio_multisubscriber_queue-0.4.1.tar.gz",
            "has_sig": false,
            "md5_digest": "684c2427f46e9360e673b1fa27210911",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": ">=3.10,<4",
            "size": 3896,
            "upload_time": "2022-12-02T22:52:04",
            "upload_time_iso_8601": "2022-12-02T22:52:04.520398Z",
            "url": "https://files.pythonhosted.org/packages/dc/05/f9bd03c03def2332f4fd555586f6120786147fca95a745e2d939027e007d/asyncio_multisubscriber_queue-0.4.1.tar.gz",
            "yanked": false,
            "yanked_reason": null
        }
    ],
    "upload_time": "2022-12-02 22:52:04",
    "github": true,
    "gitlab": false,
    "bitbucket": false,
    "github_user": "smithk86",
    "github_project": "asyncio-multisubscriber-queue",
    "travis_ci": false,
    "coveralls": false,
    "github_actions": true,
    "lcname": "asyncio-multisubscriber-queue"
}