@@ -1173,14 +1173,18 @@ describe('ParseLiveQuery', function () {
1173
1173
const client = await Parse . CoreManager . getLiveQueryController ( ) . getDefaultLiveQueryClient ( ) ;
1174
1174
client . serverURL = 'ws://localhost:1345/1' ;
1175
1175
const query = await new Parse . Query ( 'Yolo' ) . subscribe ( ) ;
1176
+ let liveQueryConnectionCount = await getConnectionsCount ( server . liveQueryServer . server ) ;
1177
+ expect ( liveQueryConnectionCount > 0 ) . toBe ( true ) ;
1176
1178
await Promise . all ( [
1177
1179
server . handleShutdown ( ) ,
1178
1180
new Promise ( resolve => query . on ( 'close' , resolve ) ) ,
1179
1181
] ) ;
1180
- await new Promise ( resolve => setTimeout ( resolve , 100 ) ) ;
1182
+ await sleep ( 100 ) ;
1181
1183
expect ( server . liveQueryServer . server . address ( ) ) . toBeNull ( ) ;
1182
1184
expect ( server . liveQueryServer . subscriber . isOpen ) . toBeFalse ( ) ;
1183
- await new Promise ( resolve => server . server . close ( resolve ) ) ;
1185
+
1186
+ liveQueryConnectionCount = await getConnectionsCount ( server . liveQueryServer . server ) ;
1187
+ expect ( liveQueryConnectionCount ) . toBe ( 0 ) ;
1184
1188
} ) ;
1185
1189
1186
1190
it_id ( '45655b74-716f-4fa1-a058-67eb21f3c3db' ) ( it ) ( 'does shutdown separate liveQuery server' , async ( ) => {
@@ -1245,7 +1249,7 @@ describe('ParseLiveQuery', function () {
1245
1249
new Promise ( resolve => query . on ( 'close' , resolve ) ) ,
1246
1250
] ) ;
1247
1251
expect ( close ) . toBe ( true ) ;
1248
- await new Promise ( resolve => setTimeout ( resolve , 100 ) ) ;
1252
+ await sleep ( 100 ) ;
1249
1253
expect ( parseServer . liveQueryServer . server . address ( ) ) . toBeNull ( ) ;
1250
1254
expect ( parseServer . liveQueryServer . subscriber . isOpen ) . toBeFalse ( ) ;
1251
1255
0 commit comments