@@ 89-100 (lines=12) @@ | ||
86 | $request = $this->applyApiSettingsToRequest($request, $options); |
|
87 | $executioner = $this->constructMiddlewares($options); |
|
88 | ||
89 | return $executioner->pre($request)->then(function (RequestInterface $request) use ($options) { |
|
90 | $body = $request->getBody(); |
|
91 | if ($body instanceof ReadableStreamInterface) { |
|
92 | $this->loop->futureTick(function () use ($body) { |
|
93 | $body->resume(); |
|
94 | }); |
|
95 | } |
|
96 | ||
97 | return resolve($this->browser->send( |
|
98 | $request |
|
99 | )); |
|
100 | }, function (ResponseInterface $response) { |
|
101 | return resolve($response); |
|
102 | })->then(function (ResponseInterface $response) use ($executioner) { |
|
103 | $body = $response->getBody(); |
|
@@ 109-118 (lines=10) @@ | ||
106 | } |
|
107 | ||
108 | return $executioner->post($response); |
|
109 | })->then(function (ResponseInterface $response) { |
|
110 | $body = $response->getBody(); |
|
111 | if ($body instanceof ReadableStreamInterface) { |
|
112 | $this->loop->futureTick(function () use ($body) { |
|
113 | $body->resume(); |
|
114 | }); |
|
115 | } |
|
116 | ||
117 | return resolve($response); |
|
118 | })->otherwise(function (Throwable $throwable) use ($executioner) { |
|
119 | return reject($executioner->error($throwable)); |
|
120 | }); |
|
121 | } |