@@ -21,7 +21,7 @@ namespace $ {
21
21
} )
22
22
23
23
server . on ( 'upgrade' ,
24
- ( req , sock , head ) => $mol_wire_async ( this ) . ws_upgrade ( req , sock , head )
24
+ ( req , sock , head : Buffer < ArrayBuffer > ) => $mol_wire_async ( this ) . ws_upgrade ( req , sock , head )
25
25
)
26
26
27
27
server . listen ( this . port ( ) , ( ) => {
@@ -87,7 +87,7 @@ namespace $ {
87
87
ws_upgrade (
88
88
req : InstanceType < $node [ 'http' ] [ 'IncomingMessage' ] > ,
89
89
socket : InstanceType < $node [ 'stream' ] [ 'Duplex' ] > ,
90
- head : Buffer ,
90
+ head : Buffer < ArrayBuffer > ,
91
91
) {
92
92
93
93
const port = $mol_rest_port_ws_node . make ( { socket } )
@@ -146,7 +146,7 @@ namespace $ {
146
146
socket . on ( 'end' , onclose )
147
147
socket . on ( 'error' , onclose )
148
148
149
- socket . on ( 'data' , ( chunk : Buffer ) => this . ws_income ( chunk , upgrade , socket ) )
149
+ socket . on ( 'data' , ( chunk : Buffer < ArrayBuffer > ) => this . ws_income ( chunk , upgrade , socket ) )
150
150
151
151
const key_in = req . headers [ "sec-websocket-key" ]
152
152
const magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'
@@ -169,11 +169,11 @@ namespace $ {
169
169
170
170
}
171
171
172
- _ws_income_chunks = new WeakMap < InstanceType < typeof $node . stream . Duplex > , Uint8Array [ ] >
173
- _ws_income_frames = new WeakMap < InstanceType < typeof $node . stream . Duplex > , ( string | Uint8Array ) [ ] >
172
+ _ws_income_chunks = new WeakMap < InstanceType < typeof $node . stream . Duplex > , Uint8Array < ArrayBuffer > [ ] >
173
+ _ws_income_frames = new WeakMap < InstanceType < typeof $node . stream . Duplex > , ( string | Uint8Array < ArrayBuffer > ) [ ] >
174
174
175
175
async ws_income (
176
- chunk : Buffer ,
176
+ chunk : Buffer < ArrayBuffer > ,
177
177
upgrade : $mol_rest_message ,
178
178
sock : InstanceType < typeof $node . stream . Duplex > ,
179
179
) {
@@ -209,7 +209,7 @@ namespace $ {
209
209
sock . unshift ( tail )
210
210
}
211
211
212
- let data : string | Uint8Array = new Uint8Array ( chunk . buffer , chunk . byteOffset + frame . size ( ) , frame . data ( ) . size )
212
+ let data : string | Uint8Array < ArrayBuffer > = new Uint8Array ( chunk . buffer , chunk . byteOffset + frame . size ( ) , frame . data ( ) . size )
213
213
214
214
if ( frame . data ( ) . mask ) {
215
215
const mask = frame . mask ( )
@@ -235,10 +235,10 @@ namespace $ {
235
235
if ( typeof frames [ 0 ] === 'string' ) {
236
236
data = ( frames as string [ ] ) . join ( '' )
237
237
} else {
238
- const size = ( frames as Uint8Array [ ] ) . reduce ( ( s , f ) => s + f . byteLength , 0 )
238
+ const size = ( frames as Uint8Array < ArrayBuffer > [ ] ) . reduce ( ( s , f ) => s + f . byteLength , 0 )
239
239
data = new Uint8Array ( size )
240
240
let offset = 0
241
- for ( const frame of ( frames as Uint8Array [ ] ) ) {
241
+ for ( const frame of ( frames as Uint8Array < ArrayBuffer > [ ] ) ) {
242
242
data . set ( frame , offset )
243
243
offset += frame . byteLength
244
244
}
0 commit comments