summaryrefslogtreecommitdiff
path: root/kombu/async/hub.py
Commit message (Expand)AuthorAgeFilesLines
* Rename `async` keyword to `asynchronous` (#839)Thomas Achtemichuk2018-03-191-380/+0
* Fix infinite loop in create_loop (#760)Gabriel Amram2017-07-101-6/+15
* Adds pydocstyle as a tox targetAsk Solem2016-10-111-1/+3
* Reorganizes kombu.utils.__init__ packageAsk Solem2016-07-161-1/+2
* Use Google-style docstringsAsk Solem2016-07-161-9/+4
* Make sure __repr__ and __str__ returns bytes on Python 2Ask Solem2016-04-111-1/+2
* Use unicode_litereals everywhere and updates flakeplus target to --2.7Ask Solem2016-04-061-1/+1
* Now uses vine for promisesAsk Solem2016-03-021-1/+1
* No log for event unregistered. Closes #549Ask Solem2015-12-161-5/+0
* Hub: Treat any unknown event as error and log the event (Issue celery/celery#...Ask Solem2015-12-021-0/+17
* Hub: Make sure fd is unregistered if register failsAsk Solem2015-12-021-7/+11
* Single item tuples no longer require whitespaceAsk Solem2015-07-131-2/+2
* Async: fire_timers always using 1s delayAsk Solem2014-08-081-1/+1
* Merge branch 'master' into curlclientcurlclientAsk Solem2014-06-111-31/+35
|\
| * Hub._ready is now a setAsk Solem2014-06-041-6/+7
| * Fixes flakes after flake8 upgradeAsk Solem2014-05-271-15/+15
| * Removes kombu.utils.compat.get_errnoAsk Solem2014-05-211-3/+2
| * Be selective about how file descriptors are removed since they may be reused ...Roger Hu2014-05-191-12/+18
* | Initial import of kombu.async.awsAsk Solem2014-05-031-4/+5
* | Async HTTP client using curlAsk Solem2014-05-031-0/+5
|/
* Hub: move debug helpers into separate moduleAsk Solem2014-02-061-49/+7
* Normalize fd in Hub.addIonel Cristian Mărieș2014-01-311-2/+3
* Hub: Do not attempt to call unregister on closed pollerAsk Solem2014-01-161-1/+3
* Hub.close now sets hub.poller to NoneAsk Solem2014-01-081-1/+2
* Do not remove gen on StopIteration, generators must handle this manuallyAsk Solem2013-11-071-3/+4
* Eventloop: Small improvementsAsk Solem2013-11-011-3/+11
* Unregister on EBADFAsk Solem2013-10-311-2/+8
* Do not automatically register all connectionts in the event loopAsk Solem2013-10-251-0/+1
* Fixes problems with time vs monotonicAsk Solem2013-10-141-1/+0
* Use call_soon rather than generator draining events from amqp transportsAsk Solem2013-10-081-9/+1
* Adds loop.call_soon and loop.run_foreverAsk Solem2013-10-071-9/+58
* Removes useless maybe_blockAsk Solem2013-10-031-23/+1
* Timer API now using secs instead of msecsAsk Solem2013-10-021-3/+3
* Adds kombu.async.timer (+ accidentally staged documentation fixes)Ask Solem2013-10-011-1/+11
* Removes Connection.more_to_read + .nb_keep_drainingasyncmoveAsk Solem2013-09-301-3/+14
* Merge branch 'master' into asyncmoveAsk Solem2013-09-251-1/+29
|\
| * Do not check heartbeats when in blocking sectionsAsk Solem2013-09-251-1/+5
| * Adds kombu.async.maybe_block contextAsk Solem2013-09-251-0/+25
* | Fixes TypeErrorAsk Solem2013-09-231-2/+5
* | Async API now closer to TulipAsk Solem2013-09-231-39/+142
|/
* Moves celery.worker.hub here as kombu.asyncAsk Solem2013-09-191-0/+195