Roland Conybeare
28b6d457c0
git-subtree-dir: xo-reactor git-subtree-mainline:dd1a6b1afcgit-subtree-split:e3a53d10e6
99 lines
3.4 KiB
C++
99 lines
3.4 KiB
C++
/* @file Sink.test.cpp */
|
|
|
|
#include "xo/reactor/PollingReactor.hpp"
|
|
#include "xo/reactor/Sink.hpp"
|
|
#include "xo/indentlog/print/pair.hpp"
|
|
#include "catch2/catch.hpp"
|
|
|
|
namespace xo {
|
|
using xo::reactor::Reactor;
|
|
using xo::reactor::PollingReactor;
|
|
using xo::reactor::AbstractSink;
|
|
using xo::reactor::Sink1;
|
|
using xo::reactor::SinkEndpoint;
|
|
using xo::reactor::SinkToConsole;
|
|
using xo::time::utc_nanos;
|
|
|
|
namespace {
|
|
class TestSink : public SinkEndpoint<int> {
|
|
public:
|
|
TestSink() = default;
|
|
|
|
virtual uint32_t n_in_ev() const override { return 0; }
|
|
virtual bool allow_volatile_source() const override { return true; }
|
|
virtual void notify_ev(int const & ev) override {}
|
|
virtual void display(std::ostream & os) const override { os << "<TestSink>"; }
|
|
}; /*TestSink*/
|
|
|
|
class TestSink2 : public SinkEndpoint<utc_nanos> {
|
|
public:
|
|
TestSink2() = default;
|
|
|
|
virtual uint32_t n_in_ev() const override { return 0; }
|
|
virtual bool allow_volatile_source() const override { return true; }
|
|
virtual void notify_ev(utc_nanos const & ev) override {}
|
|
virtual void display(std::ostream & os) const override { os << "<TestSink2>"; }
|
|
}; /*TestSink2*/
|
|
|
|
using TestSink3 = SinkToConsole<std::pair<utc_nanos, double>>;
|
|
} /*namespace*/
|
|
|
|
namespace ut {
|
|
TEST_CASE("sink-cast", "[reactor][sink]") {
|
|
rp<TestSink> test_sink = new TestSink();
|
|
rp<AbstractSink> sink = test_sink;
|
|
|
|
TestSink * cast_sink = dynamic_cast<TestSink *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == cast_sink);
|
|
|
|
Sink1<int> * int_sink = dynamic_cast<Sink1<int> *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == int_sink);
|
|
|
|
rp<Sink1<int>> int_sink2
|
|
= Sink1<int>::require_native("TEST_CASE(sink-cast)", sink.get());
|
|
|
|
REQUIRE(test_sink.get() == int_sink2.get());
|
|
} /*TEST_CASE(sink-cast)*/
|
|
|
|
TEST_CASE("sink-cast2", "[reactor]") {
|
|
rp<TestSink2> test_sink = new TestSink2();
|
|
rp<AbstractSink> sink = test_sink;
|
|
|
|
TestSink2 * cast_sink = dynamic_cast<TestSink2 *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == cast_sink);
|
|
|
|
Sink1<utc_nanos> * dt_sink = dynamic_cast<Sink1<utc_nanos> *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == dt_sink);
|
|
|
|
rp<Sink1<utc_nanos>> dt_sink2
|
|
= Sink1<utc_nanos>::require_native("TEST_CASE(sink-cast2)", sink.get());
|
|
|
|
REQUIRE(test_sink.get() == dt_sink2.get());
|
|
} /*TEST_CASE(sink-cast2)*/
|
|
|
|
TEST_CASE("sink-cast3", "[reactor]") {
|
|
rp<TestSink3> test_sink = new TestSink3();
|
|
rp<AbstractSink> sink = test_sink;
|
|
|
|
TestSink3 * cast_sink = dynamic_cast<TestSink3 *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == cast_sink);
|
|
|
|
Sink1<std::pair<utc_nanos, double>> * ev_sink
|
|
= dynamic_cast<Sink1<std::pair<utc_nanos, double>> *>(sink.get());
|
|
|
|
REQUIRE(test_sink.get() == ev_sink);
|
|
|
|
rp<Sink1<std::pair<utc_nanos, double>>> ev_sink2
|
|
= Sink1<std::pair<utc_nanos, double>>::require_native("TEST_CASE(sink-cast3)", sink.get());
|
|
|
|
REQUIRE(test_sink.get() == ev_sink2.get());
|
|
} /*TEST_CASE(sink-cast3)*/
|
|
} /*namespace ut*/
|
|
} /*namespace xo*/
|
|
|
|
/* end Sink.test.cpp */
|