@@ -386,14 +386,10 @@ TEST_F(TestPresentation, makeSubscriber_custom)
386386
387387 Presentation presentation{mr_, scheduler_, transport_mock_};
388388
389- scheduler_.scheduleAt (1s, [&](const auto &) {
390- //
391- auto maybe_sub = presentation.makeSubscriber <Message>([](const auto &) {});
392- EXPECT_THAT (maybe_sub, VariantWith<Subscriber<Message>>(_));
389+ auto maybe_sub = presentation.makeSubscriber <Message>([](const auto &) {});
390+ EXPECT_THAT (maybe_sub, VariantWith<Subscriber<Message>>(_));
393391
394- EXPECT_CALL (msg_rx_session_mock, deinit ()).Times (1 );
395- });
396- scheduler_.spinFor (10s);
392+ EXPECT_CALL (msg_rx_session_mock, deinit ()).Times (1 );
397393}
398394
399395TEST_F (TestPresentation, makeSubscriber_raw)
@@ -639,15 +635,11 @@ TEST_F(TestPresentation, makeClient)
639635
640636 Presentation presentation{mr_, scheduler_, transport_mock_};
641637
642- scheduler_.scheduleAt (1s, [&](const auto &) {
643- //
644- auto maybe_client = presentation.makeClient <Service>(rx_params.server_node_id );
645- ASSERT_THAT (maybe_client, VariantWith<ServiceClient<Service>>(_));
638+ auto maybe_client = presentation.makeClient <Service>(rx_params.server_node_id );
639+ ASSERT_THAT (maybe_client, VariantWith<ServiceClient<Service>>(_));
646640
647- EXPECT_CALL (req_tx_session_mock, deinit ()).Times (1 );
648- EXPECT_CALL (res_rx_session_mock, deinit ()).Times (1 );
649- });
650- scheduler_.spinFor (10s);
641+ EXPECT_CALL (req_tx_session_mock, deinit ()).Times (1 );
642+ EXPECT_CALL (res_rx_session_mock, deinit ()).Times (1 );
651643}
652644
653645TEST_F (TestPresentation, makeClient_multiple_custom)
@@ -676,42 +668,38 @@ TEST_F(TestPresentation, makeClient_multiple_custom)
676668
677669 Presentation presentation{mr_, scheduler_, transport_mock_};
678670
679- scheduler_.scheduleAt (1s, [&](const auto &) {
680- //
681- auto maybe_client1a = presentation.makeClient <Custom::Service>(rx_params.server_node_id );
682- ASSERT_THAT (maybe_client1a, VariantWith<ServiceClient<Custom::Service>>(_));
671+ auto maybe_client1a = presentation.makeClient <Custom::Service>(rx_params.server_node_id );
672+ ASSERT_THAT (maybe_client1a, VariantWith<ServiceClient<Custom::Service>>(_));
683673
684- auto maybe_client1b = presentation.makeClient <Custom::Service>(rx_params.server_node_id );
685- ASSERT_THAT (maybe_client1b, VariantWith<ServiceClient<Custom::Service>>(_));
674+ auto maybe_client1b = presentation.makeClient <Custom::Service>(rx_params.server_node_id );
675+ ASSERT_THAT (maybe_client1b, VariantWith<ServiceClient<Custom::Service>>(_));
686676
687- // The same custom service but to different server
688- {
689- constexpr ResponseRxParams rx_params2{rx_params.extent_bytes , rx_params.service_id , 0x32 };
690- EXPECT_CALL (res_rx_session_mock2, getParams ()).WillOnce (Return (rx_params2));
691- EXPECT_CALL (res_rx_session_mock2, setTransferIdTimeout (_)).WillOnce (Return ());
692- EXPECT_CALL (res_rx_session_mock2, setOnReceiveCallback (_)).WillOnce (Return ());
693-
694- EXPECT_CALL (transport_mock_, makeResponseRxSession (ResponseRxParamsEq (rx_params2))) //
695- .WillOnce (Invoke ([&](const auto &) { //
696- return libcyphal::detail::makeUniquePtr<UniquePtrResRxSpec>(mr_, res_rx_session_mock2);
697- }));
698- constexpr RequestTxParams tx_params2{rx_params2.service_id , rx_params2.server_node_id };
699- EXPECT_CALL (transport_mock_, makeRequestTxSession (RequestTxParamsEq (tx_params2))) //
700- .WillOnce (Invoke ([&](const auto &) { //
701- return libcyphal::detail::makeUniquePtr<UniquePtrReqTxSpec>(mr_, req_tx_session_mock2);
702- }));
703-
704- auto maybe_client2 = presentation.makeClient <Custom::Service>(rx_params2.server_node_id );
705- ASSERT_THAT (maybe_client2, VariantWith<ServiceClient<Custom::Service>>(_));
706-
707- EXPECT_CALL (res_rx_session_mock2, deinit ()).Times (1 );
708- EXPECT_CALL (req_tx_session_mock2, deinit ()).Times (1 );
709- }
677+ // The same custom service but to different server
678+ {
679+ constexpr ResponseRxParams rx_params2{rx_params.extent_bytes , rx_params.service_id , 0x32 };
680+ EXPECT_CALL (res_rx_session_mock2, getParams ()).WillOnce (Return (rx_params2));
681+ EXPECT_CALL (res_rx_session_mock2, setTransferIdTimeout (_)).WillOnce (Return ());
682+ EXPECT_CALL (res_rx_session_mock2, setOnReceiveCallback (_)).WillOnce (Return ());
683+
684+ EXPECT_CALL (transport_mock_, makeResponseRxSession (ResponseRxParamsEq (rx_params2))) //
685+ .WillOnce (Invoke ([&](const auto &) { //
686+ return libcyphal::detail::makeUniquePtr<UniquePtrResRxSpec>(mr_, res_rx_session_mock2);
687+ }));
688+ constexpr RequestTxParams tx_params2{rx_params2.service_id , rx_params2.server_node_id };
689+ EXPECT_CALL (transport_mock_, makeRequestTxSession (RequestTxParamsEq (tx_params2))) //
690+ .WillOnce (Invoke ([&](const auto &) { //
691+ return libcyphal::detail::makeUniquePtr<UniquePtrReqTxSpec>(mr_, req_tx_session_mock2);
692+ }));
710693
711- EXPECT_CALL (res_rx_session_mock1, deinit ()).Times (1 );
712- EXPECT_CALL (req_tx_session_mock1, deinit ()).Times (1 );
713- });
714- scheduler_.spinFor (10s);
694+ auto maybe_client2 = presentation.makeClient <Custom::Service>(rx_params2.server_node_id );
695+ ASSERT_THAT (maybe_client2, VariantWith<ServiceClient<Custom::Service>>(_));
696+
697+ EXPECT_CALL (res_rx_session_mock2, deinit ()).Times (1 );
698+ EXPECT_CALL (req_tx_session_mock2, deinit ()).Times (1 );
699+ }
700+
701+ EXPECT_CALL (res_rx_session_mock1, deinit ()).Times (1 );
702+ EXPECT_CALL (req_tx_session_mock1, deinit ()).Times (1 );
715703}
716704
717705TEST_F (TestPresentation, makeClient_raw)
0 commit comments