@@ 75-90 (lines=16) @@ | ||
72 | $this->middleware = $this->options[Options::MIDDLEWARE]; |
|
73 | } |
|
74 | } |
|
75 | protected function preRequest( |
|
76 | array $middlewares, |
|
77 | RequestInterface $request, |
|
78 | array $options |
|
79 | ): CancellablePromiseInterface { |
|
80 | $promise = resolve($request); |
|
81 | ||
82 | foreach ($middlewares as $middleware) { |
|
83 | $requestMiddleware = $middleware; |
|
84 | $promise = $promise->then(function (RequestInterface $request) use ($options, $requestMiddleware) { |
|
85 | return $requestMiddleware->pre($request, $options); |
|
86 | }); |
|
87 | } |
|
88 | ||
89 | return $promise; |
|
90 | } |
|
91 | ||
92 | protected function postRequest( |
|
93 | array $middlewares, |
|
@@ 92-107 (lines=16) @@ | ||
89 | return $promise; |
|
90 | } |
|
91 | ||
92 | protected function postRequest( |
|
93 | array $middlewares, |
|
94 | ResponseInterface $response, |
|
95 | array $options |
|
96 | ): CancellablePromiseInterface { |
|
97 | $promise = resolve($response); |
|
98 | ||
99 | foreach ($middlewares as $middleware) { |
|
100 | $responseMiddleware = $middleware; |
|
101 | $promise = $promise->then(function (ResponseInterface $response) use ($options, $responseMiddleware) { |
|
102 | return $responseMiddleware->post($response, $options); |
|
103 | }); |
|
104 | } |
|
105 | ||
106 | return $promise; |
|
107 | } |
|
108 | ||
109 | protected function constructMiddlewares(array $options): array |
|
110 | { |