@@ -190,67 +190,63 @@ describe('Parse EventuallyQueue', () => {
190
190
assert . strictEqual ( length , 0 ) ;
191
191
} ) ;
192
192
193
- it ( 'can saveEventually' , async done => {
193
+ it ( 'can saveEventually' , async ( ) => {
194
194
const parseServer = await reconfigureServer ( ) ;
195
195
const object = new TestObject ( { hash : 'saveSecret' } ) ;
196
- parseServer . server . close ( async ( ) => {
197
- await object . saveEventually ( ) ;
198
- let length = await Parse . EventuallyQueue . length ( ) ;
199
- assert ( Parse . EventuallyQueue . isPolling ( ) ) ;
200
- assert . strictEqual ( length , 1 ) ;
201
-
202
- await reconfigureServer ( { } ) ;
203
- while ( Parse . EventuallyQueue . isPolling ( ) ) {
204
- await sleep ( 100 ) ;
205
- }
206
- assert . strictEqual ( Parse . EventuallyQueue . isPolling ( ) , false ) ;
207
-
208
- while ( await Parse . EventuallyQueue . length ( ) ) {
209
- await sleep ( 100 ) ;
210
- }
211
- length = await Parse . EventuallyQueue . length ( ) ;
212
- assert . strictEqual ( length , 0 ) ;
213
-
214
- const query = new Parse . Query ( TestObject ) ;
215
- query . equalTo ( 'hash' , 'saveSecret' ) ;
216
- let results = await query . find ( ) ;
217
- while ( results . length === 0 ) {
218
- results = await query . find ( ) ;
219
- }
220
- assert . strictEqual ( results . length , 1 ) ;
221
- done ( ) ;
222
- } ) ;
196
+ await new Promise ( ( resolve ) => parseServer . server . close ( resolve ) ) ;
197
+ await object . saveEventually ( ) ;
198
+ let length = await Parse . EventuallyQueue . length ( ) ;
199
+ assert ( Parse . EventuallyQueue . isPolling ( ) ) ;
200
+ assert . strictEqual ( length , 1 ) ;
201
+
202
+ await reconfigureServer ( { } ) ;
203
+ while ( Parse . EventuallyQueue . isPolling ( ) ) {
204
+ await sleep ( 100 ) ;
205
+ }
206
+ assert . strictEqual ( Parse . EventuallyQueue . isPolling ( ) , false ) ;
207
+
208
+ while ( await Parse . EventuallyQueue . length ( ) ) {
209
+ await sleep ( 100 ) ;
210
+ }
211
+ length = await Parse . EventuallyQueue . length ( ) ;
212
+ assert . strictEqual ( length , 0 ) ;
213
+
214
+ const query = new Parse . Query ( TestObject ) ;
215
+ query . equalTo ( 'hash' , 'saveSecret' ) ;
216
+ let results = await query . find ( ) ;
217
+ while ( results . length === 0 ) {
218
+ results = await query . find ( ) ;
219
+ }
220
+ assert . strictEqual ( results . length , 1 ) ;
223
221
} ) ;
224
222
225
- it ( 'can destroyEventually' , async done => {
223
+ it ( 'can destroyEventually' , async ( ) => {
226
224
const parseServer = await reconfigureServer ( ) ;
227
225
const object = new TestObject ( { hash : 'deleteSecret' } ) ;
228
226
await object . save ( ) ;
229
- parseServer . server . close ( async ( ) => {
230
- await object . destroyEventually ( ) ;
231
- let length = await Parse . EventuallyQueue . length ( ) ;
232
- assert ( Parse . EventuallyQueue . isPolling ( ) ) ;
233
- assert . strictEqual ( length , 1 ) ;
234
-
235
- await reconfigureServer ( { } ) ;
236
- while ( Parse . EventuallyQueue . isPolling ( ) ) {
237
- await sleep ( 100 ) ;
238
- }
239
- assert . strictEqual ( Parse . EventuallyQueue . isPolling ( ) , false ) ;
240
- while ( await Parse . EventuallyQueue . length ( ) ) {
241
- await sleep ( 100 ) ;
242
- }
243
- length = await Parse . EventuallyQueue . length ( ) ;
244
- assert . strictEqual ( length , 0 ) ;
245
-
246
- const query = new Parse . Query ( TestObject ) ;
247
- query . equalTo ( 'hash' , 'deleteSecret' ) ;
248
- let results = await query . find ( ) ;
249
- while ( results . length ) {
250
- results = await query . find ( ) ;
251
- }
252
- assert . strictEqual ( results . length , 0 ) ;
253
- done ( ) ;
254
- } ) ;
227
+ await new Promise ( ( resolve ) => parseServer . server . close ( resolve ) ) ;
228
+ await object . destroyEventually ( ) ;
229
+ let length = await Parse . EventuallyQueue . length ( ) ;
230
+ assert ( Parse . EventuallyQueue . isPolling ( ) ) ;
231
+ assert . strictEqual ( length , 1 ) ;
232
+
233
+ await reconfigureServer ( { } ) ;
234
+ while ( Parse . EventuallyQueue . isPolling ( ) ) {
235
+ await sleep ( 100 ) ;
236
+ }
237
+ assert . strictEqual ( Parse . EventuallyQueue . isPolling ( ) , false ) ;
238
+ while ( await Parse . EventuallyQueue . length ( ) ) {
239
+ await sleep ( 100 ) ;
240
+ }
241
+ length = await Parse . EventuallyQueue . length ( ) ;
242
+ assert . strictEqual ( length , 0 ) ;
243
+
244
+ const query = new Parse . Query ( TestObject ) ;
245
+ query . equalTo ( 'hash' , 'deleteSecret' ) ;
246
+ let results = await query . find ( ) ;
247
+ while ( results . length ) {
248
+ results = await query . find ( ) ;
249
+ }
250
+ assert . strictEqual ( results . length , 0 ) ;
255
251
} ) ;
256
252
} ) ;
0 commit comments