@@ 238-248 (lines=11) @@ | ||
235 | /** |
|
236 | * @param HttpRequest $request |
|
237 | */ |
|
238 | public function setConnectionTimeout(HttpRequest $request) |
|
239 | { |
|
240 | if ($this->options['connect_timeout'] > 0) { |
|
241 | $this->connectionTimer = $this->loop->addTimer( |
|
242 | $this->options['connect_timeout'], |
|
243 | function () use ($request) { |
|
244 | $request->closeError(new \Exception('Connection time out')); |
|
245 | } |
|
246 | ); |
|
247 | } |
|
248 | } |
|
249 | ||
250 | /** |
|
251 | * @param HttpRequest $request |
|
@@ 253-263 (lines=11) @@ | ||
250 | /** |
|
251 | * @param HttpRequest $request |
|
252 | */ |
|
253 | public function setRequestTimeout(HttpRequest $request) |
|
254 | { |
|
255 | if ($this->options['timeout'] > 0) { |
|
256 | $this->requestTimer = $this->loop->addTimer( |
|
257 | $this->options['timeout'], |
|
258 | function () use ($request) { |
|
259 | $request->closeError(new \Exception('Transaction time out')); |
|
260 | } |
|
261 | ); |
|
262 | } |
|
263 | } |
|
264 | ||
265 | protected function onHeadersWritten() |
|
266 | { |