@@ -369,7 +369,7 @@ private void Update()
369
369
writer . Write ( NetworkConfig . ConnectionData ) ;
370
370
}
371
371
}
372
- Send ( clientId , "MLAPI_CONNECTION_REQUEST" , "MLAPI_INTERNAL" , writeStream . GetBuffer ( ) ) ;
372
+ Send ( clientId , "MLAPI_CONNECTION_REQUEST" , "MLAPI_INTERNAL" , writeStream . GetBuffer ( ) , null , true ) ;
373
373
}
374
374
}
375
375
break ;
@@ -866,7 +866,7 @@ internal void PassthroughSend(int targetId, int sourceId, ushort messageType, in
866
866
}
867
867
}
868
868
869
- internal void Send ( int clientId , string messageType , string channelName , byte [ ] data , uint ? networkId = null )
869
+ internal void Send ( int clientId , string messageType , string channelName , byte [ ] data , uint ? networkId = null , bool skipQueue = false )
870
870
{
871
871
if ( clientId == - 1 && isHost )
872
872
{
@@ -910,7 +910,10 @@ internal void Send(int clientId, string messageType, string channelName, byte[]
910
910
}
911
911
if ( isPassthrough )
912
912
clientId = serverClientId ;
913
- NetworkTransport . QueueMessageForSending ( hostId , clientId , MessageManager . channels [ channelName ] , stream . GetBuffer ( ) , sizeOfStream , out error ) ;
913
+ if ( skipQueue )
914
+ NetworkTransport . Send ( hostId , clientId , MessageManager . channels [ channelName ] , stream . GetBuffer ( ) , sizeOfStream , out error ) ;
915
+ else
916
+ NetworkTransport . QueueMessageForSending ( hostId , clientId , MessageManager . channels [ channelName ] , stream . GetBuffer ( ) , sizeOfStream , out error ) ;
914
917
}
915
918
}
916
919
@@ -1185,7 +1188,7 @@ private void HandleApproval(int clientId, bool approved)
1185
1188
}
1186
1189
}
1187
1190
}
1188
- Send ( clientId , "MLAPI_CONNECTION_APPROVED" , "MLAPI_INTERNAL" , writeStream . GetBuffer ( ) ) ;
1191
+ Send ( clientId , "MLAPI_CONNECTION_APPROVED" , "MLAPI_INTERNAL" , writeStream . GetBuffer ( ) , null , true ) ;
1189
1192
}
1190
1193
1191
1194
//Inform old clients of the new player
0 commit comments