|
10 | 10 | use React\Promise\Promise; |
11 | 11 | use React\Stream\ThroughStream; |
12 | 12 | use React\Tests\Http\TestCase; |
| 13 | +use React\Promise\PromiseInterface; |
13 | 14 |
|
14 | 15 | final class LimitHandlersMiddlewareTest extends TestCase |
15 | 16 | { |
@@ -203,6 +204,75 @@ public function testReceivesNextRequestAfterPreviousHandlerIsSettled() |
203 | 204 | $middleware($request, $this->expectCallableOnceWith($request)); |
204 | 205 | } |
205 | 206 |
|
| 207 | + public function testPendingRequestCanBeCancelledAndForwardsCancellationToInnerPromise() |
| 208 | + { |
| 209 | + $request = new ServerRequest( |
| 210 | + 'POST', |
| 211 | + 'http://example.com/', |
| 212 | + array(), |
| 213 | + 'hello' |
| 214 | + ); |
| 215 | + |
| 216 | + $once = $this->expectCallableOnce(); |
| 217 | + $deferred = new Deferred(function () use ($once) { |
| 218 | + $once(); |
| 219 | + throw new \RuntimeException('Cancelled'); |
| 220 | + }); |
| 221 | + $middleware = new LimitHandlersMiddleware(1); |
| 222 | + $promise = $middleware($request, function () use ($deferred) { |
| 223 | + return $deferred->promise(); |
| 224 | + }); |
| 225 | + |
| 226 | + $this->assertTrue($promise instanceof PromiseInterface); |
| 227 | + $promise->cancel(); |
| 228 | + } |
| 229 | + |
| 230 | + public function testQueuedRequestCanBeCancelledBeforeItStartsProcessing() |
| 231 | + { |
| 232 | + $request = new ServerRequest( |
| 233 | + 'POST', |
| 234 | + 'http://example.com/', |
| 235 | + array(), |
| 236 | + 'hello' |
| 237 | + ); |
| 238 | + |
| 239 | + $deferred = new Deferred(); |
| 240 | + $middleware = new LimitHandlersMiddleware(1); |
| 241 | + $middleware($request, function () use ($deferred) { |
| 242 | + return $deferred->promise(); |
| 243 | + }); |
| 244 | + |
| 245 | + $promise = $middleware($request, $this->expectCallableNever()); |
| 246 | + |
| 247 | + $this->assertTrue($promise instanceof PromiseInterface); |
| 248 | + $promise->cancel(); |
| 249 | + $promise->then(null, $this->expectCallableOnce()); |
| 250 | + } |
| 251 | + |
| 252 | + public function testReceivesNextRequestAfterPreviousHandlerIsCancelled() |
| 253 | + { |
| 254 | + $request = new ServerRequest( |
| 255 | + 'POST', |
| 256 | + 'http://example.com/', |
| 257 | + array(), |
| 258 | + 'hello' |
| 259 | + ); |
| 260 | + |
| 261 | + $deferred = new Deferred(function () { |
| 262 | + throw new \RuntimeException('Cancelled'); |
| 263 | + }); |
| 264 | + $middleware = new LimitHandlersMiddleware(1); |
| 265 | + $promise = $middleware($request, function () use ($deferred) { |
| 266 | + return $deferred->promise(); |
| 267 | + }); |
| 268 | + |
| 269 | + $this->assertTrue($promise instanceof PromiseInterface); |
| 270 | + $promise->cancel(); |
| 271 | + $promise->then(null, $this->expectCallableOnce()); |
| 272 | + |
| 273 | + $middleware($request, $this->expectCallableOnceWith($request)); |
| 274 | + } |
| 275 | + |
206 | 276 | public function testReceivesNextStreamingBodyWithSameDataAfterPreviousHandlerIsSettled() |
207 | 277 | { |
208 | 278 | $stream = new ThroughStream(); |
|
0 commit comments