@@ -20,7 +20,7 @@ export class Socket extends EventEmitter {
20
20
private upgrading : boolean ;
21
21
private upgraded : boolean ;
22
22
private writeBuffer : Packet [ ] ;
23
- private packetsFn : any [ ] ;
23
+ private packetsFn : Array < ( ) => void > ;
24
24
private sentCallbackFn : any [ ] ;
25
25
private cleanupFn : any [ ] ;
26
26
private checkIntervalTimer ;
@@ -431,12 +431,27 @@ export class Socket extends EventEmitter {
431
431
* @return {Socket } for chaining
432
432
* @api public
433
433
*/
434
- public send ( data , options , callback ?) {
434
+ public send (
435
+ data : RawData ,
436
+ options ?: { compress : boolean } ,
437
+ callback ?: ( ) => void
438
+ ) {
435
439
this . sendPacket ( "message" , data , options , callback ) ;
436
440
return this ;
437
441
}
438
442
439
- public write ( data , options , callback ?) {
443
+ /**
444
+ * Alias of {@link send}.
445
+ *
446
+ * @param data
447
+ * @param options
448
+ * @param callback
449
+ */
450
+ public write (
451
+ data : RawData ,
452
+ options ?: { compress : boolean } ,
453
+ callback ?: ( ) => void
454
+ ) {
440
455
this . sendPacket ( "message" , data , options , callback ) ;
441
456
return this ;
442
457
}
@@ -451,15 +466,17 @@ export class Socket extends EventEmitter {
451
466
*
452
467
* @api private
453
468
*/
454
- private sendPacket ( type : PacketType , data ?: RawData , options ?, callback ?) {
469
+ private sendPacket (
470
+ type : PacketType ,
471
+ data ?: RawData ,
472
+ options : { compress : boolean } = { compress : true } ,
473
+ callback ?: ( ) => void
474
+ ) {
455
475
if ( "function" === typeof options ) {
456
476
callback = options ;
457
477
options = null ;
458
478
}
459
479
460
- options = options || { } ;
461
- options . compress = false !== options . compress ;
462
-
463
480
if ( "closing" !== this . readyState && "closed" !== this . readyState ) {
464
481
debug ( 'sending packet "%s" (%s)' , type , data ) ;
465
482
0 commit comments