用于将传感器数据发送到客户端的流式处理通道。每个传感器 都有自己的 FDataStream。但请注意,此类不提供 send 函数。 为了发送数据,需要使用 “MakeAsyncDataStream” 函数 创建一个 FAsyncDataStream。 FAsyncDataStream 允许从任何线程发送数据。 更多...
#include <DataStream.h>
Public 类型 | |
using | StreamType = T |
Public 成员函数 | |
bool | AreClientsListening () |
FDataStreamTmpl ()=default | |
FDataStreamTmpl (StreamType InStream) | |
uint64_t | GetSensorType () |
auto | GetToken () const |
返回允许订阅此流的令牌。 | |
bool | IsStreamReady () |
template<typename SensorT > | |
FAsyncDataStreamTmpl< T > | MakeAsyncDataStream (const SensorT &Sensor, double Timestamp) |
创建 FAsyncDataStream 对象。 | |
Private 属性 | |
boost::optional< StreamType > | Stream |
用于将传感器数据发送到客户端的流式处理通道。每个传感器 都有自己的 FDataStream。但请注意,此类不提供 send 函数。 为了发送数据,需要使用 “MakeAsyncDataStream” 函数 创建一个 FAsyncDataStream。 FAsyncDataStream 允许从任何线程发送数据。
在文件 DataStream.h 第 26 行定义.
using FDataStreamTmpl< T >::StreamType = T |
在文件 DataStream.h 第 30 行定义.
|
default |
|
inline |
在文件 DataStream.h 第 34 行定义.
|
inline |
|
inline |
在文件 DataStream.h 第 58 行定义.
引用了 FDataStreamTmpl< T >::Stream.
被这些函数引用 AGnssSensor::PostPhysTick(), ADVSCamera::PostPhysTick() , 以及 AInertialMeasurementUnit::PostPhysTick().
|
inline |
返回允许订阅此流的令牌。
在文件 DataStream.h 第 52 行定义.
引用了 FDataStreamTmpl< T >::Stream.
被这些函数引用 ASensor::EndPlay(), FCameraGBufferUint8::GetToken(), FCameraGBufferFloat::GetToken() , 以及 FWorldObserver::GetToken().
|
inline |
在文件 DataStream.h 第 46 行定义.
引用了 FDataStreamTmpl< T >::Stream.
被这些函数引用 FWorldObserver::BroadcastTick().
|
inline |
创建 FAsyncDataStream 对象。
在文件 DataStream.h 第 40 行定义.
引用了 FDataStreamTmpl< T >::Stream.
被这些函数引用 FWorldObserver::BroadcastTick(), FCameraGBufferUint8::GetDataStream() , 以及 FCameraGBufferFloat::GetDataStream().
|
private |
在文件 DataStream.h 第 72 行定义.
被这些函数引用 FDataStreamTmpl< T >::AreClientsListening(), FDataStreamTmpl< T >::GetSensorType(), FDataStreamTmpl< T >::GetToken(), FDataStreamTmpl< T >::IsStreamReady(), FDataStreamTmpl< T >::MakeAsyncDataStream(), FAsyncDataStreamTmpl::Send() , 以及 FAsyncDataStreamTmpl::SerializeAndSend().