Searched refs:pubHandler (Results 1 – 3 of 3) sorted by relevance
1522 StrictMock<MockHTTPHandler> pubHandler; in TEST_F() local1548 EXPECT_CALL(pubHandler, onEOM()); in TEST_F()1610 StrictMock<MockHTTPHandler> pubHandler; in TEST_F() local1613 exTxn->setHandler(&pubHandler); in TEST_F()1614 pubHandler.txn_ = exTxn; in TEST_F()1619 pubHandler.expectHeaders([&] { in TEST_F()1623 EXPECT_CALL(pubHandler, onEOM()); in TEST_F()1707 exTxn->setHandler(&pubHandler); in TEST_F()1708 pubHandler.txn_ = exTxn; in TEST_F()1713 pubHandler.expectHeaders([&] { in TEST_F()[all …]
823 NiceMock<MockHTTPHandler> pubHandler; in TEST_F() local830 .WillOnce(Invoke([&pubHandler](HTTPTransaction* pubTxn) { in TEST_F()831 pubTxn->setHandler(&pubHandler); in TEST_F()832 pubHandler.txn_ = pubTxn; in TEST_F()834 pubHandler.expectHeaders([&](std::shared_ptr<HTTPMessage> msg) { in TEST_F()837 pubHandler.expectEOM([&]() { pubHandler.txn_->sendAbort(); }); in TEST_F()838 pubHandler.expectDetachTransaction(); in TEST_F()
530 const OnPublishReceivedHandler &pubHandler = pair.second; in Subscribe() local533 [pubHandler]( in Subscribe()535 pubHandler(connection, topic, payload); in Subscribe()