@@ -108,6 +108,8 @@ export interface Handshake {
108
108
auth : { [ key : string ] : any } ;
109
109
}
110
110
111
+ type Event = [ eventName : string , ...args : any [ ] ] ;
112
+
111
113
export class Socket <
112
114
ListenEvents extends EventsMap = DefaultEventsMap ,
113
115
EmitEvents extends EventsMap = ListenEvents ,
@@ -130,8 +132,7 @@ export class Socket<
130
132
private readonly server : Server < ListenEvents , EmitEvents , ServerSideEvents > ;
131
133
private readonly adapter : Adapter ;
132
134
private acks : Map < number , ( ) => void > = new Map ( ) ;
133
- private fns : Array < ( event : Array < any > , next : ( err ?: Error ) => void ) => void > =
134
- [ ] ;
135
+ private fns : Array < ( event : Event , next : ( err ?: Error ) => void ) => void > = [ ] ;
135
136
private flags : BroadcastFlags = { } ;
136
137
private _anyListeners ?: Array < ( ...args : any [ ] ) => void > ;
137
138
@@ -569,7 +570,7 @@ export class Socket<
569
570
* @param {Array } event - event that will get emitted
570
571
* @private
571
572
*/
572
- private dispatch ( event : [ eventName : string , ... args : any [ ] ] ) : void {
573
+ private dispatch ( event : Event ) : void {
573
574
debug ( "dispatching an event %j" , event ) ;
574
575
this . run ( event , ( err ) => {
575
576
process . nextTick ( ( ) => {
@@ -592,9 +593,7 @@ export class Socket<
592
593
* @return {Socket } self
593
594
* @public
594
595
*/
595
- public use (
596
- fn : ( event : Array < any > , next : ( err ?: Error ) => void ) => void
597
- ) : this {
596
+ public use ( fn : ( event : Event , next : ( err ?: Error ) => void ) => void ) : this {
598
597
this . fns . push ( fn ) ;
599
598
return this ;
600
599
}
@@ -606,10 +605,7 @@ export class Socket<
606
605
* @param {Function } fn - last fn call in the middleware
607
606
* @private
608
607
*/
609
- private run (
610
- event : [ eventName : string , ...args : any [ ] ] ,
611
- fn : ( err : Error | null ) => void
612
- ) : void {
608
+ private run ( event : Event , fn : ( err : Error | null ) => void ) : void {
613
609
const fns = this . fns . slice ( 0 ) ;
614
610
if ( ! fns . length ) return fn ( null ) ;
615
611
0 commit comments