A client able to subscribe to multiple streams. 更多...
#include <Client.h>
Public 类型 | |
using | protocol_type = typename underlying_client::protocol_type |
using | token_type = carla::streaming::detail::token_type |
using | underlying_client = T |
Public 成员函数 | |
Client () | |
Client (boost::asio::ip::address fallback_address) | |
Client (const std::string &fallback_address) | |
template<typename Functor > | |
void | Subscribe (boost::asio::io_context &io_context, token_type token, Functor &&callback) |
void | UnSubscribe (token_type token) |
~Client () | |
Private 属性 | |
std::unordered_map< detail::stream_id_type, std::shared_ptr< underlying_client > > | _clients |
boost::asio::ip::address | _fallback_address |
A client able to subscribe to multiple streams.
Accepts an external io_context.
在文件 streaming/low_level/Client.h 第 27 行定义.
using carla::streaming::low_level::Client< T >::protocol_type = typename underlying_client::protocol_type |
在文件 streaming/low_level/Client.h 第 31 行定义.
using carla::streaming::low_level::Client< T >::token_type = carla::streaming::detail::token_type |
在文件 streaming/low_level/Client.h 第 32 行定义.
using carla::streaming::low_level::Client< T >::underlying_client = T |
在文件 streaming/low_level/Client.h 第 30 行定义.
|
inlineexplicit |
在文件 streaming/low_level/Client.h 第 34 行定义.
|
inlineexplicit |
在文件 streaming/low_level/Client.h 第 37 行定义.
|
inlineexplicit |
在文件 streaming/low_level/Client.h 第 40 行定义.
|
inline |
|
inline |
在文件 streaming/low_level/Client.h 第 52 行定义.
引用了 carla::streaming::low_level::Client< T >::_clients, carla::streaming::low_level::Client< T >::_fallback_address, DEBUG_ASSERT_EQ, carla::streaming::detail::token_type::get_stream_id(), carla::streaming::detail::token_type::has_address() , 以及 carla::streaming::detail::token_type::set_address().
被这些函数引用 carla::streaming::Client::Subscribe(), TEST() , 以及 TEST().
|
inline |
在文件 streaming/low_level/Client.h 第 68 行定义.
引用了 carla::streaming::low_level::Client< T >::_clients, carla::streaming::detail::token_type::get_stream_id() , 以及 carla::log_debug().
被这些函数引用 TEST() , 以及 carla::streaming::Client::UnSubscribe().
|
private |
|
private |
在文件 streaming/low_level/Client.h 第 79 行定义.
被这些函数引用 carla::streaming::low_level::Client< T >::Subscribe().