{ "info": { "author": "Cameron Simpson", "author_email": "cs@cskk.id.au", "bugtrack_url": null, "classifiers": [ "Development Status :: 4 - Beta", "Intended Audience :: Developers", "License :: OSI Approved :: GNU General Public License v3 or later (GPLv3+)", "Operating System :: OS Independent", "Programming Language :: Python", "Programming Language :: Python :: 2", "Programming Language :: Python :: 3", "Topic :: Software Development :: Libraries :: Python Modules" ], "description": "*Latest release 20191007*:\nPushQueue: improve __str__.\nClean lint, drop cs.obj dependency.\n\nQueue-like items: iterable queues and channels.\n\n## Class `Channel`\n\nA zero-storage data passage.\nUnlike a Queue(1), put() blocks waiting for the matching get().\n\n## Function `IterablePriorityQueue(*args, capacity=0, name=None, **kw)`\n\nFactory to create an iterable PriorityQueue.\n\n## Function `IterableQueue(*args, capacity=0, name=None, **kw)`\n\nFactory to create an iterable Queue.\n\n## Class `NullQueue`\n\nMRO: `cs.resources.MultiOpenMixin` \nA queue-like object that discards its inputs.\nCalls to .get() raise Queue_Empty.\n\n### Method `NullQueue.__init__(self, blocking=False, name=None)`\n\nInitialise the NullQueue.\n\nParameters:\n* `blocking`: if true, calls to .get() block until .shutdown().\n Default: False.\n* `name`: a name for this NullQueue.\n\n## Class `PushQueue`\n\nMRO: `cs.resources.MultiOpenMixin` \nA puttable object which looks like an iterable Queue.\n\nCalling .put(item) calls `func_push` supplied at initialisation\nto trigger a function on data arrival, whose processing is mediated\nqueued via a Later for delivery to the output queue.\n\n### Method `PushQueue.__init__(self, name, functor, outQ)`\n\nInitialise the PushQueue with the Later `L`, the callable `functor`\nand the output queue `outQ`.\n\nParameters:\n* `functor` is a one-to-many function which accepts a single\n item of input and returns an iterable of outputs; it may be a\n generator. These outputs are passed to outQ.put individually as\n received.\n* `outQ` is a MultiOpenMixin which accepts via its .put() method.\n\n## Class `TimerQueue`\n\nClass to run a lot of \"in the future\" jobs without using a bazillion\nTimer threads.\n\n\n\n# Release Log\n\n*Release 20191007*:\nPushQueue: improve __str__.\nClean lint, drop cs.obj dependency.\n\n*Release 20190812*:\n_QueueIterator: do MultiOpenMixin.__init__ so that __str__ is functional.\n\n*Release 20181022*:\nBugfix Channel, drasticly simplify PushQueue, other minor changes.\n\n*Release 20160828*:\nUse \"install_requires\" instead of \"requires\" in DISTINFO.\nTimerQueue.add: support optional *a and **kw arguments for func.\nMany bugfixes and internal changes.\n\n*Release 20150115*:\nMore PyPI metadata fixups.\n\n*Release 20150111*:\nInitial PyPI release.", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "https://bitbucket.org/cameron_simpson/css/commits/all", "keywords": "python2,python3", "license": "GNU General Public License v3 or later (GPLv3+)", "maintainer": "", "maintainer_email": "", "name": "cs.queues", "package_url": "https://pypi.org/project/cs.queues/", "platform": "", "project_url": "https://pypi.org/project/cs.queues/", "project_urls": { "Homepage": "https://bitbucket.org/cameron_simpson/css/commits/all" }, "release_url": "https://pypi.org/project/cs.queues/20191007/", "requires_dist": null, "requires_python": "", "summary": "some Queue subclasses and ducktypes", "version": "20191007" }, "last_serial": 5936657, "releases": { "20150115": [ { "comment_text": "", "digests": { "md5": "333a1dc09928ae5bb241d26841d24545", "sha256": "74ca35771810211c1f6be7121b2652d4c27bf622105a058bf6fc807228287bf3" }, "downloads": -1, "filename": "cs.queues-20150115.tar.gz", "has_sig": false, "md5_digest": "333a1dc09928ae5bb241d26841d24545", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5667, "upload_time": "2015-01-18T06:12:34", "url": "https://files.pythonhosted.org/packages/c8/36/39246be15d0a87944a5ce37ffeaa601a862c0b1881e24785c8d9b3d16495/cs.queues-20150115.tar.gz" } ], "20160828": [ { "comment_text": "", "digests": { "md5": "b77f3a348bf94796f30eb4c575dce04a", "sha256": "32ae660b972feaa94e7a259ddca2f743dd1d4119ffeb5d4cfd776e372e462722" }, "downloads": -1, "filename": "cs.queues-20160828.tar.gz", "has_sig": false, "md5_digest": "b77f3a348bf94796f30eb4c575dce04a", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6165, "upload_time": "2016-08-28T06:09:51", "url": "https://files.pythonhosted.org/packages/fd/a9/d084047047cc2aa8a0ec0aeaba7e533554de86ef7d849d752d11d866b255/cs.queues-20160828.tar.gz" } ], "20181022": [ { "comment_text": "", "digests": { "md5": "a98e97810c5efb3eedd54dd39b72c443", "sha256": "51be1b9a2d59c7d3d50aa949bac563301650a9c97642db14460ba40ed0e6ece5" }, "downloads": -1, "filename": "cs.queues-20181022.tar.gz", "has_sig": false, "md5_digest": "a98e97810c5efb3eedd54dd39b72c443", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 5848, "upload_time": "2018-10-22T03:32:35", "url": "https://files.pythonhosted.org/packages/41/ed/0c8c274eb0221f3b48903a50f5a02e5e10c7f28ad1ed41e90ea8214dba24/cs.queues-20181022.tar.gz" } ], "20190812": [ { "comment_text": "", "digests": { "md5": "528bd9d3ab170bd49f0b83191d08954e", "sha256": "5b24356a8e19d19151a1944351f7b145e9cd21c37fe0416ed6ec32e39674a336" }, "downloads": -1, "filename": "cs.queues-20190812.tar.gz", "has_sig": false, "md5_digest": "528bd9d3ab170bd49f0b83191d08954e", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6452, "upload_time": "2019-08-12T00:10:21", "url": "https://files.pythonhosted.org/packages/e6/14/82369f3cc7ab975f1369e546a41e0b590a920c57c9ba468e34c2ef7153f5/cs.queues-20190812.tar.gz" } ], "20191007": [ { "comment_text": "", "digests": { "md5": "cd94b942cbea331bebc4bf2538d8aae6", "sha256": "9d38c0abfc56d0d6b74b0489e7c83232a619d4e49809fcd76f5543fbdea63d03" }, "downloads": -1, "filename": "cs.queues-20191007.tar.gz", "has_sig": false, "md5_digest": "cd94b942cbea331bebc4bf2538d8aae6", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6525, "upload_time": "2019-10-07T02:42:12", "url": "https://files.pythonhosted.org/packages/cf/16/179b19ae209c2b68dd26fba65a0cb6da869b92b3de46fbf131f2e8946c16/cs.queues-20191007.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "cd94b942cbea331bebc4bf2538d8aae6", "sha256": "9d38c0abfc56d0d6b74b0489e7c83232a619d4e49809fcd76f5543fbdea63d03" }, "downloads": -1, "filename": "cs.queues-20191007.tar.gz", "has_sig": false, "md5_digest": "cd94b942cbea331bebc4bf2538d8aae6", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6525, "upload_time": "2019-10-07T02:42:12", "url": "https://files.pythonhosted.org/packages/cf/16/179b19ae209c2b68dd26fba65a0cb6da869b92b3de46fbf131f2e8946c16/cs.queues-20191007.tar.gz" } ] }