@@ -39,8 +39,8 @@ describe('strategy.serialize()', () => {
39
39
name : 'add' ,
40
40
} ) ;
41
41
42
- const job1 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
43
- const job2 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
42
+ const job1 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
43
+ const job2 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
44
44
expect ( started ) . toBe ( 0 ) ;
45
45
expect ( finished ) . toBe ( 0 ) ;
46
46
@@ -102,8 +102,8 @@ describe('strategy.serialize()', () => {
102
102
name : 'add100' ,
103
103
} ) ;
104
104
105
- const job1 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
106
- const job2 = await scheduler . schedule ( 'add100' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
105
+ const job1 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
106
+ const job2 = scheduler . schedule ( 'add100' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
107
107
expect ( started ) . toBe ( 0 ) ;
108
108
expect ( finished ) . toBe ( 0 ) ;
109
109
@@ -159,8 +159,8 @@ describe('strategy.reuse()', () => {
159
159
name : 'add' ,
160
160
} ) ;
161
161
162
- const job1 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
163
- const job2 = await scheduler . schedule ( 'add' , [ ] ) ;
162
+ const job1 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
163
+ const job2 = scheduler . schedule ( 'add' , [ ] ) ;
164
164
expect ( started ) . toBe ( 0 ) ;
165
165
expect ( finished ) . toBe ( 0 ) ;
166
166
@@ -179,8 +179,8 @@ describe('strategy.reuse()', () => {
179
179
expect ( job1 . state ) . toBe ( JobState . Ended ) ;
180
180
expect ( job2 . state ) . toBe ( JobState . Ended ) ;
181
181
182
- const job3 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
183
- const job4 = await scheduler . schedule ( 'add' , [ ] ) ;
182
+ const job3 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
183
+ const job4 = scheduler . schedule ( 'add' , [ ] ) ;
184
184
job3 . output . subscribe ( ) ;
185
185
expect ( started ) . toBe ( 2 ) ;
186
186
expect ( finished ) . toBe ( 1 ) ;
@@ -226,10 +226,10 @@ describe('strategy.memoize()', () => {
226
226
name : 'add' ,
227
227
} ) ;
228
228
229
- const job1 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
230
- const job2 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
231
- const job3 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
232
- const job4 = await scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
229
+ const job1 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
230
+ const job2 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 ] ) ;
231
+ const job3 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
232
+ const job4 = scheduler . schedule ( 'add' , [ 1 , 2 , 3 , 4 , 5 ] ) ;
233
233
expect ( started ) . toBe ( 0 ) ;
234
234
expect ( finished ) . toBe ( 0 ) ;
235
235
0 commit comments