@@ -32,20 +32,10 @@ export function addSyncTransport(
32
32
pendingMessageBusMessagesToSend . push ( { data : [ data ] , address : address ?? [ ] } )
33
33
} )
34
34
35
- function getMessagesToSend ( ) : [ Uint8Array [ ] , typeof pendingMessageBusMessagesToSend ] {
35
+ function getMessagesToSend ( ) : typeof pendingMessageBusMessagesToSend {
36
36
const messages = [ ...pendingMessageBusMessagesToSend ]
37
37
pendingMessageBusMessagesToSend . length = 0
38
- const broadcastMessages : Uint8Array [ ] = [ ]
39
- const peerMessages : typeof pendingMessageBusMessagesToSend = [ ]
40
-
41
- for ( const message of messages ) {
42
- if ( ! message . address . length ) {
43
- broadcastMessages . push ( ...message . data )
44
- } else {
45
- peerMessages . push ( message )
46
- }
47
- }
48
- return [ broadcastMessages , peerMessages ]
38
+ return messages
49
39
}
50
40
const players = definePlayerHelper ( engine )
51
41
@@ -61,9 +51,9 @@ export function addSyncTransport(
61
51
console . log ( ...Array . from ( serializeCrdtMessages ( '[NetworkMessage sent]:' , message , engine ) ) )
62
52
binaryMessageBus . emit ( CommsMessage . CRDT , message )
63
53
}
64
- const [ broadcastMessages , peerMessages ] = getMessagesToSend ( )
54
+ const peerMessages = getMessagesToSend ( )
65
55
66
- const response = await sendBinary ( { data : broadcastMessages , peerData : peerMessages } )
56
+ const response = await sendBinary ( { data : [ ] , peerData : peerMessages } )
67
57
binaryMessageBus . __processMessages ( response . data )
68
58
transportInitialzed = true
69
59
} ,
0 commit comments