#include <Stream.h>
Public 成员函数 | |
bool | AreClientsListening () |
检查是否有客户端正在监听 | |
Buffer | MakeBuffer () |
从与此流关联的缓冲池中获取一个缓冲区。被丢弃的缓冲区将被重用以避免内存分配。 | |
template<typename T > | |
Stream & | operator<< (const T &data) |
复制 data 并将其刷新到流中。 | |
Stream & | operator= (const Stream &)=default |
Stream & | operator= (Stream &&)=default |
Stream ()=delete | |
Stream (const Stream &)=default | |
Stream (Stream &&)=default | |
Token | token () const |
与此流关联的 Token。客户端可使用该 Token 订阅此流。 | |
template<typename... Buffers> | |
void | Write (Buffers &&... buffers) |
将 buffers 刷新到流中。不会进行复制。 | |
Private 成员函数 | |
Stream (std::shared_ptr< StreamStateT > state) | |
Private 属性 | |
std::shared_ptr< StreamStateT > | _shared_state |
友元 | |
class | detail::Dispatcher |
在文件 detail/Stream.h 第 22 行定义.
|
delete |
|
default |
|
default |
|
inlineprivate |
在文件 detail/Stream.h 第 70 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::_shared_state , 以及 DEBUG_ASSERT.
|
inline |
检查是否有客户端正在监听
在文件 detail/Stream.h 第 62 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::_shared_state.
|
inline |
从与此流关联的缓冲池中获取一个缓冲区。被丢弃的缓冲区将被重用以避免内存分配。
在文件 detail/Stream.h 第 41 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::_shared_state.
被这些函数引用 carla::streaming::detail::Stream< StreamStateT >::operator<<().
|
inline |
复制 data 并将其刷新到流中。
在文件 detail/Stream.h 第 54 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::MakeBuffer() , 以及 carla::streaming::detail::Stream< StreamStateT >::Write().
|
default |
|
default |
|
inline |
与此流关联的 Token。客户端可使用该 Token 订阅此流。
在文件 detail/Stream.h 第 34 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::_shared_state.
被这些函数引用 Benchmark::AddStream() , 以及 FCarlaServer::FPimpl::BindActions().
|
inline |
将 buffers 刷新到流中。不会进行复制。
在文件 detail/Stream.h 第 48 行定义.
引用了 carla::streaming::detail::Stream< StreamStateT >::_shared_state.
被这些函数引用 carla::streaming::detail::Stream< StreamStateT >::operator<<().
|
friend |
在文件 detail/Stream.h 第 68 行定义.
|
private |
在文件 detail/Stream.h 第 75 行定义.
被这些函数引用 carla::streaming::detail::Stream< StreamStateT >::AreClientsListening(), carla::streaming::detail::Stream< StreamStateT >::MakeBuffer(), carla::streaming::detail::Stream< StreamStateT >::Stream(), carla::streaming::detail::Stream< StreamStateT >::token() , 以及 carla::streaming::detail::Stream< StreamStateT >::Write().