A streaming channel for sending sensor data to clients. More...
#include <AsyncDataStream.h>
Public Types | |
using | StreamType = T |
Public Member Functions | |
bool | AreClientsListening () |
FDataStreamTmpl ()=default | |
FDataStreamTmpl (StreamType InStream) | |
uint64_t | GetSensorType () |
auto | GetToken () const |
Return the token that allows subscribing to this stream. More... | |
bool | IsStreamReady () |
template<typename SensorT > | |
FAsyncDataStreamTmpl< T > | MakeAsyncDataStream (const SensorT &Sensor, double Timestamp) |
Create a FAsyncDataStream object. More... | |
Private Attributes | |
boost::optional< StreamType > | Stream |
A streaming channel for sending sensor data to clients.
Each sensor has its own FDataStream. Note however that this class does not provide a send function. In order to send data, a FAsyncDataStream needs to be created using "MakeAsyncDataStream" function. FAsyncDataStream allows sending data from any thread.
Definition at line 18 of file AsyncDataStream.h.
using FDataStreamTmpl< T >::StreamType = T |
Definition at line 30 of file DataStream.h.
|
default |
|
inline |
Definition at line 34 of file DataStream.h.
|
inline |
Definition at line 64 of file DataStream.h.
Referenced by ASensor::Tick().
|
inline |
Definition at line 58 of file DataStream.h.
Referenced by AGnssSensor::PostPhysTick(), AInertialMeasurementUnit::PostPhysTick(), and ADVSCamera::PostPhysTick().
|
inline |
Return the token that allows subscribing to this stream.
Definition at line 52 of file DataStream.h.
Referenced by ASensor::EndPlay(), FWorldObserver::GetToken(), FCameraGBufferUint8::GetToken(), and FCameraGBufferFloat::GetToken().
|
inline |
Definition at line 46 of file DataStream.h.
Referenced by FWorldObserver::BroadcastTick().
|
inline |
Create a FAsyncDataStream object.
Definition at line 40 of file DataStream.h.
Referenced by FWorldObserver::BroadcastTick(), FCameraGBufferUint8::GetDataStream(), and FCameraGBufferFloat::GetDataStream().
|
private |
Definition at line 72 of file DataStream.h.
Referenced by FDataStreamTmpl< carla::streaming::Stream >::AreClientsListening(), FDataStreamTmpl< carla::streaming::Stream >::GetSensorType(), FDataStreamTmpl< carla::streaming::Stream >::GetToken(), FDataStreamTmpl< carla::streaming::Stream >::IsStreamReady(), and FDataStreamTmpl< carla::streaming::Stream >::MakeAsyncDataStream().