Navigation
API > API/Plugins > API/Plugins/ConcertSyncCore > API/Plugins/ConcertSyncCore/Replication > API/Plugins/ConcertSyncCore/Replication/Processing
Inheritance Hierarchy
- IReplicationDataSource
- IReplicationCacheUser
- TSharedFromThis
- FReplicationDataQueuer
References
| Module | ConcertSyncCore |
| Header | /Engine/Plugins/Developer/Concert/ConcertSync/ConcertSyncCore/Source/ConcertSyncCore/Public/Replication/Processing/ReplicationDataQueuer.h |
| Include | #include "Replication/Processing/ReplicationDataQueuer.h" |
Syntax
class FReplicationDataQueuer :
public UE::ConcertSyncCore::IReplicationDataSource ,
public UE::ConcertSyncCore::IReplicationCacheUser ,
public TSharedFromThis< FReplicationDataQueuer >
Remarks
Holds on to events received from remote endpoints and exposes them as a source.
Received events are received from a FObjectReplicationCache, which makes sure that event data is shared effectively if you created multiple FReplicationDataQueuer based on the same cache. This is relevant server side, where a FReplicationDataQueuer is created for each client.
Child classes need to implement IReplicationCacheUser::WantsToAcceptObject. TODO: Remove object data if the object is is meant for becomes unavailable.
Functions
| Type | Name | Description | |
|---|---|---|---|
 |
void | BindToCache
(
FObjectReplicationCache& InReplicationCache |
Called by subclass factory functions. |
Overridden from IReplicationDataSource
| Type | Name | Description | |
|---|---|---|---|
  |
bool | ExtractReplicationDataForObject
(
const FConcertReplicatedObjectId& Object, |
Extracts data for Object. |
   |
void | ForEachPendingObject
(
TFunctionRef< void(const FPendingObjectReplicationInfo&)> ProcessItemFunc |
Iterates the objects that must be processed for replication (the result of ExtractReplicationDataForObject MAY return something new). |
   |
int32 | NumObjects () |
Overridden from IReplicationCacheUser
| Type | Name | Description | |
|---|---|---|---|
  |
void | OnCachedDataUpdated
(
const FConcertReplicatedObjectId& Object, |
This function is called when new data is received while this cache user is still holding on to an object previously received with OnDataCached. |
  |
void | OnDataCached
(
const FConcertReplicatedObjectId& Object, |
Called when data that is interesting to this user becomes available. |