| 516 | |
| 517 | template <typename Message, typename UnionType, typename From, typename To> |
| 518 | Future<process::Message> FutureUnionMessage( |
| 519 | Message message, UnionType unionType, From from, To to, bool drop = false) |
| 520 | { |
| 521 | TestsFilter* filter = |
| 522 | FilterTestEventListener::instance()->install(); |
| 523 | |
| 524 | Future<process::Message> future; |
| 525 | synchronized (filter->mutex) { |
| 526 | EXPECT_CALL(filter->mock, filter(to, testing::A<const MessageEvent&>())) |
| 527 | .With(UnionMessageMatcher(message, unionType, from)) |
| 528 | .WillOnce(testing::DoAll(FutureArgNotPointerField<1>( |
| 529 | &MessageEvent::message, |
| 530 | &future), |
| 531 | testing::Return(drop))) |
| 532 | .RetiresOnSaturation(); // Don't impose any subsequent expectations. |
| 533 | } |
| 534 | |
| 535 | return future; |
| 536 | } |
| 537 | |
| 538 | |
| 539 | template <typename PID, typename Method> |
nothing calls this directly
no test coverage detected