WIP More changes to unit tests

components/streams/test/recsend_unit.cpp

@@ -210,11 +210,13 @@ TEST_CASE( "Multi-thread stability testing" ) {
 		auto h = receiver->onFrameSet([&count,&result](const ftl::data::FrameSetPtr &fs) {
 			LOG(INFO) << "FS RECV: " << fs->timestamp();
 			count++;
-			if (result) REQUIRE( result->timestamp() <= fs->timestamp()-20 );
+			if (result) {
+				REQUIRE( result->timestamp() <= fs->timestamp()-20 );
 				REQUIRE( fs->frames.size() == 2 );
 				REQUIRE( fs->isComplete() );
 				REQUIRE( fs->frames[0].hasChannel(Channel::Colour) );
 				REQUIRE( fs->frames[1].hasChannel(Channel::Colour) );
+			}
 			result = fs;
 			return true;
 		});
@@ -269,6 +271,8 @@ TEST_CASE( "Multi-thread stability testing" ) {
 
 	ftl::timer::reset();
 	ftl::timer::setInterval(50);
+	ftl::pool.clear_queue();
+	while (ftl::pool.n_idle() != ftl::pool.size()) std::this_thread::sleep_for(std::chrono::milliseconds(10));
 
 	delete receiver;
 	delete sender;