diff options
| author | raittes <raittes@gmail.com> | 2021-02-11 14:34:13 -0300 |
|---|---|---|
| committer | Asif Saif Uddin <auvipy@gmail.com> | 2021-02-12 10:35:01 +0600 |
| commit | 264617305514b5fcc567002c24910506a98b0e4e (patch) | |
| tree | f5ab9a645b9eb6f5540eb774ed86f65044c40e9f | |
| parent | c19693902c1616d53815607bb966a0b25b53d236 (diff) | |
| download | kombu-264617305514b5fcc567002c24910506a98b0e4e.tar.gz | |
kombu/asynchronous/http/curl: implement _set_timeout
| -rw-r--r-- | kombu/asynchronous/http/curl.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kombu/asynchronous/http/curl.py b/kombu/asynchronous/http/curl.py index 9f972469..df9fc7d8 100644 --- a/kombu/asynchronous/http/curl.py +++ b/kombu/asynchronous/http/curl.py @@ -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() |