CARLA
 
载入中...
搜索中...
未找到
Public 成员函数 | Private 类型 | Private 属性 | 所有成员列表
carla::streaming::Client类 参考

A client able to subscribe to multiple streams. 更多...

#include <Client.h>

+ carla::streaming::Client 的协作图:

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.h23 行定义.

成员类型定义说明

◆ underlying_client

在文件 streaming/Client.h24 行定义.

构造及析构函数说明

◆ Client() [1/2]

carla::streaming::Client::Client ( )
default

◆ Client() [2/2]

carla::streaming::Client::Client ( const std::string & fallback_address)
inlineexplicit

在文件 streaming/Client.h29 行定义.

◆ ~Client()

carla::streaming::Client::~Client ( )
inline

在文件 streaming/Client.h32 行定义.

引用了 _service , 以及 carla::ThreadPool::Stop().

+ 函数调用图:

成员函数说明

◆ AsyncRun()

void carla::streaming::Client::AsyncRun ( size_t worker_threads)
inline

在文件 streaming/Client.h51 行定义.

引用了 _service , 以及 carla::ThreadPool::AsyncRun().

被这些函数引用 carla::client::detail::Client::Pimpl::Pimpl() , 以及 TEST().

+ 函数调用图:
+ 这是这个函数的调用关系图:

◆ Run()

void carla::streaming::Client::Run ( )
inline

在文件 streaming/Client.h47 行定义.

引用了 _service , 以及 carla::ThreadPool::Run().

+ 函数调用图:

◆ Subscribe()

template<typename Functor >
void carla::streaming::Client::Subscribe ( const Token & token,
Functor && callback )
inline
警告
cannot subscribe twice to the same stream (even if it's a MultiStream).

在文件 streaming/Client.h39 行定义.

引用了 _client, _service, carla::ThreadPool::io_context() , 以及 carla::streaming::low_level::Client< T >::Subscribe().

被这些函数引用 Benchmark::AddStream() , 以及 TEST().

+ 函数调用图:
+ 这是这个函数的调用关系图:

◆ UnSubscribe()

void carla::streaming::Client::UnSubscribe ( const Token & token)
inline

在文件 streaming/Client.h43 行定义.

引用了 _client , 以及 carla::streaming::low_level::Client< T >::UnSubscribe().

+ 函数调用图:

类成员变量说明

◆ _client

underlying_client carla::streaming::Client::_client
private

在文件 streaming/Client.h61 行定义.

被这些函数引用 Subscribe() , 以及 UnSubscribe().

◆ _service

ThreadPool carla::streaming::Client::_service
private

在文件 streaming/Client.h59 行定义.

被这些函数引用 AsyncRun(), Run(), Subscribe() , 以及 ~Client().


该类的文档由以下文件生成: