mirror of https://github.com/celery/kombu.git
kombu/asynchronous/http/curl: implement _set_timeout
This commit is contained in:
parent
c19693902c
commit
2646173055
|
@ -100,7 +100,7 @@ class CurlClient(BaseClient):
|
|||
self._fds[fd] = READ | WRITE
|
||||
|
||||
def _set_timeout(self, msecs):
|
||||
pass # TODO
|
||||
self.hub.call_later(msecs, self._timeout_check)
|
||||
|
||||
def _timeout_check(self, _pycurl=pycurl):
|
||||
self._pop_from_hub()
|
||||
|
|
Loading…
Reference in New Issue