A client able to subscribe to multiple streams. 更多...
#include <Client.h>
Public 成员函数 | |
void | AsyncRun (size_t worker_threads) |
Client ()=default | |
Client (const std::string &fallback_address) | |
void | Run () |
template<typename Functor > | |
void | Subscribe (const Token &token, Functor &&callback) |
void | UnSubscribe (const Token &token) |
~Client () | |
Private 类型 | |
using | underlying_client = low_level::Client<detail::tcp::Client> |
Private 属性 | |
underlying_client | _client |
ThreadPool | _service |
A client able to subscribe to multiple streams.
在文件 streaming/Client.h 第 23 行定义.
在文件 streaming/Client.h 第 24 行定义.
|
default |
|
inlineexplicit |
在文件 streaming/Client.h 第 29 行定义.
|
inline |
|
inline |
在文件 streaming/Client.h 第 51 行定义.
引用了 _service , 以及 carla::ThreadPool::AsyncRun().
被这些函数引用 carla::client::detail::Client::Pimpl::Pimpl() , 以及 TEST().
|
inline |
|
inline |
在文件 streaming/Client.h 第 39 行定义.
引用了 _client, _service, carla::ThreadPool::io_context() , 以及 carla::streaming::low_level::Client< T >::Subscribe().
被这些函数引用 Benchmark::AddStream() , 以及 TEST().
|
inline |
在文件 streaming/Client.h 第 43 行定义.
引用了 _client , 以及 carla::streaming::low_level::Client< T >::UnSubscribe().
|
private |
在文件 streaming/Client.h 第 61 行定义.
被这些函数引用 Subscribe() , 以及 UnSubscribe().
|
private |
在文件 streaming/Client.h 第 59 行定义.
被这些函数引用 AsyncRun(), Run(), Subscribe() , 以及 ~Client().