| 471 | typename Path, |
| 472 | typename Deserializer> |
| 473 | Future<http::Request> FutureUnionHttpRequest( |
| 474 | Message message, |
| 475 | UnionType unionType, |
| 476 | Path path, |
| 477 | Deserializer deserializer, |
| 478 | bool drop = false) |
| 479 | { |
| 480 | TestsFilter* filter = FilterTestEventListener::instance()->install(); |
| 481 | Future<http::Request> future; |
| 482 | synchronized (filter->mutex) { |
| 483 | EXPECT_CALL(filter->mock, filter( |
| 484 | testing::A<const UPID&>(), |
| 485 | testing::A<const HttpEvent&>())) |
| 486 | .With(UnionHttpMatcher(message, unionType, path, deserializer)) |
| 487 | .WillOnce(testing::DoAll(FutureArgField<1>( |
| 488 | &HttpEvent::request, |
| 489 | &future), |
| 490 | testing::Return(drop))) |
| 491 | .RetiresOnSaturation(); // Don't impose any subsequent expectations. |
| 492 | } |
| 493 | |
| 494 | return future; |
| 495 | } |
| 496 | |
| 497 | |
| 498 | template <typename Name, typename From, typename To> |
nothing calls this directly
no test coverage detected