@@ -26,14 +26,14 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
26
26
* @return a new BroadcastOperator instance
27
27
* @public
28
28
*/
29
- public to ( room : Room | Room [ ] ) : BroadcastOperator < EmitEvents , SocketData > {
29
+ public to ( room : Room | Room [ ] ) {
30
30
const rooms = new Set ( this . rooms ) ;
31
31
if ( Array . isArray ( room ) ) {
32
32
room . forEach ( ( r ) => rooms . add ( r ) ) ;
33
33
} else {
34
34
rooms . add ( room ) ;
35
35
}
36
- return new BroadcastOperator (
36
+ return new BroadcastOperator < EmitEvents , SocketData > (
37
37
this . adapter ,
38
38
rooms ,
39
39
this . exceptRooms ,
@@ -48,7 +48,7 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
48
48
* @return a new BroadcastOperator instance
49
49
* @public
50
50
*/
51
- public in ( room : Room | Room [ ] ) : BroadcastOperator < EmitEvents , SocketData > {
51
+ public in ( room : Room | Room [ ] ) {
52
52
return this . to ( room ) ;
53
53
}
54
54
@@ -59,16 +59,14 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
59
59
* @return a new BroadcastOperator instance
60
60
* @public
61
61
*/
62
- public except (
63
- room : Room | Room [ ]
64
- ) : BroadcastOperator < EmitEvents , SocketData > {
62
+ public except ( room : Room | Room [ ] ) {
65
63
const exceptRooms = new Set ( this . exceptRooms ) ;
66
64
if ( Array . isArray ( room ) ) {
67
65
room . forEach ( ( r ) => exceptRooms . add ( r ) ) ;
68
66
} else {
69
67
exceptRooms . add ( room ) ;
70
68
}
71
- return new BroadcastOperator (
69
+ return new BroadcastOperator < EmitEvents , SocketData > (
72
70
this . adapter ,
73
71
this . rooms ,
74
72
exceptRooms ,
@@ -83,11 +81,9 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
83
81
* @return a new BroadcastOperator instance
84
82
* @public
85
83
*/
86
- public compress (
87
- compress : boolean
88
- ) : BroadcastOperator < EmitEvents , SocketData > {
84
+ public compress ( compress : boolean ) {
89
85
const flags = Object . assign ( { } , this . flags , { compress } ) ;
90
- return new BroadcastOperator (
86
+ return new BroadcastOperator < EmitEvents , SocketData > (
91
87
this . adapter ,
92
88
this . rooms ,
93
89
this . exceptRooms ,
@@ -103,9 +99,9 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
103
99
* @return a new BroadcastOperator instance
104
100
* @public
105
101
*/
106
- public get volatile ( ) : BroadcastOperator < EmitEvents , SocketData > {
102
+ public get volatile ( ) {
107
103
const flags = Object . assign ( { } , this . flags , { volatile : true } ) ;
108
- return new BroadcastOperator (
104
+ return new BroadcastOperator < EmitEvents , SocketData > (
109
105
this . adapter ,
110
106
this . rooms ,
111
107
this . exceptRooms ,
@@ -119,9 +115,9 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
119
115
* @return a new BroadcastOperator instance
120
116
* @public
121
117
*/
122
- public get local ( ) : BroadcastOperator < EmitEvents , SocketData > {
118
+ public get local ( ) {
123
119
const flags = Object . assign ( { } , this . flags , { local : true } ) ;
124
- return new BroadcastOperator (
120
+ return new BroadcastOperator < EmitEvents , SocketData > (
125
121
this . adapter ,
126
122
this . rooms ,
127
123
this . exceptRooms ,
@@ -144,7 +140,7 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
144
140
*/
145
141
public timeout ( timeout : number ) {
146
142
const flags = Object . assign ( { } , this . flags , { timeout } ) ;
147
- return new BroadcastOperator (
143
+ return new BroadcastOperator < EmitEvents , SocketData > (
148
144
this . adapter ,
149
145
this . rooms ,
150
146
this . exceptRooms ,
@@ -255,9 +251,7 @@ export class BroadcastOperator<EmitEvents extends EventsMap, SocketData>
255
251
*
256
252
* @public
257
253
*/
258
- public fetchSockets < SocketData = any > ( ) : Promise <
259
- RemoteSocket < EmitEvents , SocketData > [ ]
260
- > {
254
+ public fetchSockets ( ) : Promise < RemoteSocket < EmitEvents , SocketData > [ ] > {
261
255
return this . adapter
262
256
. fetchSockets ( {
263
257
rooms : this . rooms ,
@@ -359,7 +353,10 @@ export class RemoteSocket<EmitEvents extends EventsMap, SocketData>
359
353
this . handshake = details . handshake ;
360
354
this . rooms = new Set ( details . rooms ) ;
361
355
this . data = details . data ;
362
- this . operator = new BroadcastOperator ( adapter , new Set ( [ this . id ] ) ) ;
356
+ this . operator = new BroadcastOperator < EmitEvents , SocketData > (
357
+ adapter ,
358
+ new Set ( [ this . id ] )
359
+ ) ;
363
360
}
364
361
365
362
public emit < Ev extends EventNames < EmitEvents > > (
0 commit comments