3
3
const assert = require ( 'assert' ) ;
4
4
const clear = require ( './clear' ) ;
5
5
const Parse = require ( '../../node' ) ;
6
+ const sleep = require ( './sleep' ) ;
6
7
7
8
const TestObject = Parse . Object . extend ( 'TestObject' ) ;
8
9
const DiffObject = Parse . Object . extend ( 'DiffObject' ) ;
@@ -15,7 +16,7 @@ describe('Parse LiveQuery', () => {
15
16
clear ( ) . then ( done ) . catch ( done . fail ) ;
16
17
} ) ;
17
18
18
- it ( 'can subscribe to query' , async ( ) => {
19
+ it ( 'can subscribe to query' , async ( done ) => {
19
20
const object = new TestObject ( ) ;
20
21
await object . save ( ) ;
21
22
@@ -25,12 +26,13 @@ describe('Parse LiveQuery', () => {
25
26
26
27
subscription . on ( 'update' , object => {
27
28
assert . equal ( object . get ( 'foo' ) , 'bar' ) ;
29
+ done ( ) ;
28
30
} )
29
31
object . set ( { foo : 'bar' } ) ;
30
32
await object . save ( ) ;
31
33
} ) ;
32
34
33
- it ( 'can subscribe to multiple queries' , async ( done ) => {
35
+ it ( 'can subscribe to multiple queries' , async ( ) => {
34
36
const objectA = new TestObject ( ) ;
35
37
const objectB = new TestObject ( ) ;
36
38
await Parse . Object . saveAll ( [ objectA , objectB ] ) ;
@@ -52,14 +54,11 @@ describe('Parse LiveQuery', () => {
52
54
} )
53
55
await objectA . save ( { foo : 'bar' } ) ;
54
56
await objectB . save ( { foo : 'baz' } ) ;
55
-
56
- setTimeout ( ( ) => {
57
- assert . equal ( count , 2 ) ;
58
- done ( ) ;
59
- } , 100 ) ;
57
+ await sleep ( 1000 ) ;
58
+ assert . equal ( count , 2 ) ;
60
59
} ) ;
61
60
62
- it ( 'can subscribe to multiple queries different class' , async ( done ) => {
61
+ it ( 'can subscribe to multiple queries different class' , async ( ) => {
63
62
const objectA = new TestObject ( ) ;
64
63
const objectB = new DiffObject ( ) ;
65
64
await Parse . Object . saveAll ( [ objectA , objectB ] ) ;
@@ -81,14 +80,11 @@ describe('Parse LiveQuery', () => {
81
80
} )
82
81
await objectA . save ( { foo : 'bar' } ) ;
83
82
await objectB . save ( { foo : 'baz' } ) ;
84
-
85
- setTimeout ( ( ) => {
86
- expect ( count ) . toBe ( 2 ) ;
87
- done ( ) ;
88
- } , 1000 ) ;
83
+ await sleep ( 1000 ) ;
84
+ assert . equal ( count , 2 ) ;
89
85
} ) ;
90
86
91
- it ( 'can unsubscribe to multiple queries different class' , async ( done ) => {
87
+ it ( 'can unsubscribe to multiple queries different class' , async ( ) => {
92
88
const objectA = new TestObject ( ) ;
93
89
const objectB = new DiffObject ( ) ;
94
90
await Parse . Object . saveAll ( [ objectA , objectB ] ) ;
@@ -110,14 +106,11 @@ describe('Parse LiveQuery', () => {
110
106
subscriptionA . unsubscribe ( ) ;
111
107
await objectA . save ( { foo : 'bar' } ) ;
112
108
await objectB . save ( { foo : 'baz' } ) ;
113
-
114
- setTimeout ( ( ) => {
115
- assert . equal ( count , 1 ) ;
116
- done ( ) ;
117
- } , 1000 ) ;
109
+ await sleep ( 1000 ) ;
110
+ assert . equal ( count , 1 ) ;
118
111
} ) ;
119
112
120
- it ( 'can unsubscribe with await to multiple queries different class' , async ( done ) => {
113
+ it ( 'can unsubscribe with await to multiple queries different class' , async ( ) => {
121
114
const objectA = new TestObject ( ) ;
122
115
const objectB = new DiffObject ( ) ;
123
116
await Parse . Object . saveAll ( [ objectA , objectB ] ) ;
@@ -139,10 +132,7 @@ describe('Parse LiveQuery', () => {
139
132
await subscriptionA . unsubscribe ( ) ;
140
133
await objectA . save ( { foo : 'bar' } ) ;
141
134
await objectB . save ( { foo : 'baz' } ) ;
142
-
143
- setTimeout ( ( ) => {
144
- assert . equal ( count , 1 ) ;
145
- done ( ) ;
146
- } , 1000 ) ;
135
+ await sleep ( 1000 ) ;
136
+ assert . equal ( count , 1 ) ;
147
137
} ) ;
148
138
} ) ;
0 commit comments