max_buffer_size=max_buffer_size)
timeout = min(request.connect_timeout, request.request_timeout)
if timeout:
- self._connect_timeout = self.io_loop.add_timeout(
+ self._timeout = self.io_loop.add_timeout(
self.start_time + timeout,
self._on_timeout)
self.stream.set_close_callback(self._on_close)
def _on_connect(self, parsed):
if self._timeout is not None:
- self.io_loop.remove_callback(self._timeout)
+ self.io_loop.remove_timeout(self._timeout)
self._timeout = None
if self.request.request_timeout:
self._timeout = self.io_loop.add_timeout(