@@ -129,7 +129,7 @@ public void OnCreate(ref SystemState state)
129129 state . RequireForUpdate < RpcCollection > ( ) ;
130130 state . RequireForUpdate < NetworkId > ( ) ;
131131 }
132-
132+
133133 public UnifiedNetcodeTransport Transport ;
134134 public NetworkManager NetworkManager ;
135135
@@ -139,7 +139,7 @@ public void Disconnect(Connection connection)
139139 {
140140 DisconnectQueue . Add ( connection ) ;
141141 }
142-
142+
143143 public void SendRpc ( TransportRpc rpc , Entity connectionEntity )
144144 {
145145 var rpcQueue = SystemAPI . GetSingleton < RpcCollection > ( ) . GetRpcQueue < TransportRpc , TransportRpc > ( ) ;
@@ -151,7 +151,7 @@ public void SendRpc(TransportRpc rpc, Entity connectionEntity)
151151 protected override void OnUpdate ( )
152152 {
153153 NetworkManager . MessageManager . ProcessSendQueues ( ) ;
154-
154+
155155 using var commandBuffer = new EntityCommandBuffer ( Allocator . Temp ) ;
156156 foreach ( var ( networkId , _, entity ) in SystemAPI . Query < RefRO < NetworkId > , RefRO < NetworkStreamConnection > > ( ) . WithEntityAccess ( ) )
157157 {
@@ -218,7 +218,7 @@ internal void DispatchMessage(int connectionId, in FixedBytes1280 buffer)
218218 {
219219 connectionInfo . ReceiveQueue . PushReader ( reader ) ;
220220 }
221-
221+
222222 var message = connectionInfo . ReceiveQueue . PopMessage ( ) ;
223223 while ( message . Count != 0 )
224224 {
@@ -245,7 +245,7 @@ public override unsafe void Send(ulong clientId, ArraySegment<byte> payload, Net
245245
246246 var amount = connectionInfo . SendQueue . FillWriterWithBytes ( ref writer , k_MaxPacketSize ) ;
247247 rpc . Value . Buffer . Length = amount ;
248-
248+
249249 var updateSystem = m_NetworkManager . NetcodeWorld . GetExistingSystemManaged < UnifiedNetcodeUpdateSystem > ( ) ;
250250 updateSystem . SendRpc ( rpc , connectionInfo . Connection . ConnectionEntity ) ;
251251
0 commit comments