@@ -1391,7 +1391,7 @@ void PipelinedProcessing_Test::testSharedReceiversSelector() {
13911391 CPPUNIT_ASSERT_EQUAL (std::string (" wait" ), m_deviceClient->get <std::string>(m_sender, " output1.noInputShared" ));
13921392
13931393 karabo::data::Hash config1 (m_receiverBaseConfig);
1394- config1 += Hash (" deviceId" , m_receiver1, " input. dataDistribution" , " shared" );
1394+ config1 += Hash (" deviceId" , m_receiver1, " input" , Hash ( " dataDistribution" , " shared" , " onSlowness " , " wait " ) );
13951395
13961396 karabo::data::Hash config2 (config1);
13971397 config2.set <std::string>(" deviceId" , m_receiver2);
@@ -1400,7 +1400,7 @@ void PipelinedProcessing_Test::testSharedReceiversSelector() {
14001400 instantiateDeviceWithAssert (" PipeReceiverDevice" , config2);
14011401
14021402 // Ensure that connected
1403- testSenderOutputChannelConnections (2UL , {m_receiver1 + " :input" , m_receiver2 + " :input" }, " shared" , " drop " , " local" ,
1403+ testSenderOutputChannelConnections (2UL , {m_receiver1 + " :input" , m_receiver2 + " :input" }, " shared" , " wait " , " local" ,
14041404 {m_receiver1 + " :input2" , m_receiver2 + " :input2" }, " copy" , " drop" , " local" );
14051405
14061406 // ==========================================================
0 commit comments