11 #ifndef RTI_ROUTING_ADAPTER_DETAIL_STREAM_READER_LISTENER_FORWARDER_HPP_
12 #define RTI_ROUTING_ADAPTER_DETAIL_STREAM_READER_LISTENER_FORWARDER_HPP_
14 #include <rti/core/Exception.hpp>
16 #include <routingservice/routingservice_adapter_new.h>
18 #include <rti/routing/adapter/StreamReader.hpp>
19 #include <rti/routing/adapter/DiscoveryStreamReader.hpp>
21 namespace rti {
namespace routing {
namespace adapter {
namespace detail {
36 class StreamReaderListener {
48 void on_data_available(
51 native_listener_.on_data_available(
52 static_cast<void*>(stream_reader),
53 native_listener_.listener_data);
58 const RTI_RoutingServiceStreamReaderListenerExt *native_listener) :
59 native_listener_(*native_listener)
63 ~StreamReaderListener()
69 RTI_RoutingServiceStreamReaderListenerExt native_listener_;
75 #endif // RTI_ROUTING_ADAPTER_DETAIL_STREAM_READER_LISTENER_FORWARDER_HPP_