A low-level streaming server. More...

#include <Server.h>

Public Types
using	protocol_type = typename underlying_server::protocol_type

using	stream_id = carla::streaming::detail::stream_id_type

using	token_type = carla::streaming::detail::token_type

using	underlying_server = T

Public Member Functions
void	CloseStream (carla::streaming::detail::stream_id_type id)

void	DisableForROS (stream_id sensor_id)

void	EnableForROS (stream_id sensor_id)

std::optional< stream_id >	FindStreamAlias (stream_id alias)

std::optional< token_type >	FindToken (stream_id id)

underlying_server::endpoint	GetLocalEndpoint () const

token_type	GetToken (stream_id sensor_id)

bool	IsEnabledForROS (stream_id sensor_id)

Stream	MakeStream ()

void	RemoveStreamAlias (stream_id alias)

template<typename InternalEPType >
	Server (boost::asio::io_context &io_context, detail::EndPoint< protocol_type, InternalEPType > internal_ep)

template<typename InternalEPType , typename ExternalEPType >
	Server (boost::asio::io_context &io_context, detail::EndPoint< protocol_type, InternalEPType > internal_ep, detail::EndPoint< protocol_type, ExternalEPType > external_ep)

template<typename... EPArgs>
	Server (boost::asio::io_context &io_context, EPArgs &&... args)

void	SetROS2TopicVisibilityDefaultEnabled (bool enabled)

void	SetSessionsUseStreamAliases (bool enabled)

void	SetStreamAlias (stream_id alias, stream_id target)

void	SetSynchronousMode (bool is_synchro)

void	SetTimeout (time_duration timeout)

Private Member Functions
void	StartServer ()

Private Attributes
detail::Dispatcher	_dispatcher

underlying_server	_server

Detailed Description

template<typename T>
class carla::streaming::low_level::Server< T >

A low-level streaming server.

Each new stream has a token associated, this token can be used by a client to subscribe to the stream. This server requires an external io_context running.

Warning: This server cannot be destructed before its io_context is stopped.

Definition at line 28 of file streaming/low_level/Server.h.

Member Typedef Documentation

◆ protocol_type

template<typename T >

using carla::streaming::low_level::Server< T >::protocol_type = typename underlying_server::protocol_type

Definition at line 33 of file streaming/low_level/Server.h.

◆ stream_id

template<typename T >

using carla::streaming::low_level::Server< T >::stream_id = carla::streaming::detail::stream_id_type

Definition at line 37 of file streaming/low_level/Server.h.

◆ token_type

template<typename T >

using carla::streaming::low_level::Server< T >::token_type = carla::streaming::detail::token_type

Definition at line 35 of file streaming/low_level/Server.h.

◆ underlying_server

template<typename T >

using carla::streaming::low_level::Server< T >::underlying_server = T

Definition at line 31 of file streaming/low_level/Server.h.

Constructor & Destructor Documentation

◆ Server() [1/3]

template<typename T >

template<typename InternalEPType , typename ExternalEPType >

carla::streaming::low_level::Server< T >::Server	(	boost::asio::io_context &	io_context,
		detail::EndPoint< protocol_type, InternalEPType >	internal_ep,
		detail::EndPoint< protocol_type, ExternalEPType >	external_ep
	)

inlineexplicit

Definition at line 40 of file streaming/low_level/Server.h.

References carla::streaming::low_level::Server< T >::StartServer().

◆ Server() [2/3]

template<typename T >

template<typename InternalEPType >

carla::streaming::low_level::Server< T >::Server	(	boost::asio::io_context &	io_context,
		detail::EndPoint< protocol_type, InternalEPType >	internal_ep
	)