// Custom includes
#include <algorithm>
-#include "Socket/Protocols/INet/UDPSocketHandle.hh"
-#include "Scheduler/Scheduler.hh"
+#include "../Socket/Protocols/INet/UDPSocketHandle.hh"
+#include "../Scheduler/Scheduler.hh"
#include "SocketReader.hh"
#include "DebugModules.hh"
#include "Setup.hh"
inputSocket.bind(senf::INet4SocketAddress("localhost:44344"));
inputSocket.blocking(false);
module::ActiveSocketReader<> udpReader(inputSocket);
- debug::PassivePacketSink sink;
- ppi::connect(udpReader.output, sink.input);
+ debug::PassiveSink sink;
+ ppi::connect(udpReader, sink);
std::string data ("TEST");
senf::UDPv4ClientSocketHandle outputSocket;
outputSocket.writeto(senf::INet4SocketAddress("localhost:44344"),data);
- senf::Scheduler::instance().timeout(1000, &timeout);
+ senf::Scheduler::instance().timeout(
+ senf::ClockService::now() + senf::ClockService::milliseconds(100), &timeout);
senf::ppi::run();
BOOST_REQUIRE( ! sink.empty() );