Fixed local message for host on RPCs

Author: TwoTenPvP

MLAPI/MonoBehaviours/Core/NetworkedBehaviour.cs

@@ -568,15 +568,12 @@ internal void SendServerRPCPerformance(ulong hash, Stream messageStream)
 		        messageWriter.WriteUInt64Packed(hash);
 
 		        stream.CopyFrom(messageStream);
-		        
-		        if (isHost)
-		        {
-					using (PooledBitStream localStream = PooledBitStream.Get())
-					{
-						localStream.CopyFrom(messageStream);
-						InvokeServerRPCLocal(hash, NetworkingManager.singleton.LocalClientId, localStream);
-					}
-		        }
+
+				if (isHost)
+				{
+					messageStream.Position = 0;
+					InvokeServerRPCLocal(hash, NetworkingManager.singleton.LocalClientId, messageStream);
+				}
 
 		        InternalMessageHandler.Send(NetworkingManager.singleton.NetworkConfig.NetworkTransport.ServerNetId, "MLAPI_SERVER_RPC", "MLAPI_DEFAULT_MESSAGE", stream);
 	        }
@@ -606,6 +603,7 @@ internal void SendClientRPCPerformance(ulong hash,  List<uint> clientIds, Stream
                     {
                         if (isHost && NetworkingManager.singleton.ConnectedClientsList[i].ClientId == NetworkingManager.singleton.LocalClientId)
                         {
+							messageStream.Position = 0;
                             InvokeClientRPCLocal(hash, NetworkingManager.singleton.LocalClientId, messageStream);
                         }
                         else
@@ -620,11 +618,8 @@ internal void SendClientRPCPerformance(ulong hash,  List<uint> clientIds, Stream
                     {
                         if (isHost && clientIds[i] == NetworkingManager.singleton.LocalClientId)
                         {
-	                        using (PooledBitStream localStream = PooledBitStream.Get())
-	                        {
-								localStream.CopyFrom(messageStream);
-								InvokeClientRPCLocal(hash, NetworkingManager.singleton.LocalClientId, localStream);   
-	                        }
+							messageStream.Position = 0;
+							InvokeClientRPCLocal(hash, NetworkingManager.singleton.LocalClientId, messageStream);
                         }
                         else
                         {
@@ -653,14 +648,11 @@ internal void SendClientRPCPerformance(ulong hash, uint clientId, Stream message
 
                 stream.CopyFrom(messageStream);
 
-                if (isHost && clientId == NetworkingManager.singleton.LocalClientId)
-                {
-					using (PooledBitStream localStream = PooledBitStream.Get())
-					{
-						localStream.CopyFrom(messageStream);
-						InvokeClientRPCLocal(hash, NetworkingManager.singleton.LocalClientId, localStream);
-					}
-                }
+				if (isHost && clientId == NetworkingManager.singleton.LocalClientId)
+				{
+					messageStream.Position = 0;
+					InvokeClientRPCLocal(hash, NetworkingManager.singleton.LocalClientId, messageStream);
+				}
                 else
                 {
                     InternalMessageHandler.Send(clientId, "MLAPI_CLIENT_RPC", "MLAPI_DEFAULT_MESSAGE", stream);