@@ -94,7 +94,7 @@ describe('QueueingEventProcessor', async () => {
94
94
await expect ( processor . onRunning ( ) ) . resolves . not . toThrow ( ) ;
95
95
} ) ;
96
96
97
- it ( 'should start dispatchRepeater and failedEventRepeater' , ( ) => {
97
+ it ( 'should start failedEventRepeater' , ( ) => {
98
98
const eventDispatcher = getMockDispatcher ( ) ;
99
99
const dispatchRepeater = getMockRepeater ( ) ;
100
100
const failedEventRepeater = getMockRepeater ( ) ;
@@ -107,7 +107,6 @@ describe('QueueingEventProcessor', async () => {
107
107
} ) ;
108
108
109
109
processor . start ( ) ;
110
- expect ( dispatchRepeater . start ) . toHaveBeenCalledOnce ( ) ;
111
110
expect ( failedEventRepeater . start ) . toHaveBeenCalledOnce ( ) ;
112
111
} ) ;
113
112
@@ -175,6 +174,25 @@ describe('QueueingEventProcessor', async () => {
175
174
expect ( eventDispatcher . dispatchEvent ) . toHaveBeenCalledTimes ( 0 ) ;
176
175
} ) ;
177
176
177
+ it ( 'should start the dispatchRepeater if it is not running' , async ( ) => {
178
+ const eventDispatcher = getMockDispatcher ( ) ;
179
+ const dispatchRepeater = getMockRepeater ( ) ;
180
+
181
+ const processor = new BatchEventProcessor ( {
182
+ eventDispatcher,
183
+ dispatchRepeater,
184
+ batchSize : 100 ,
185
+ } ) ;
186
+
187
+ processor . start ( ) ;
188
+ await processor . onRunning ( ) ;
189
+
190
+ const event = createImpressionEvent ( 'id-1' ) ;
191
+ await processor . process ( event ) ;
192
+
193
+ expect ( dispatchRepeater . start ) . toHaveBeenCalledOnce ( ) ;
194
+ } ) ;
195
+
178
196
it ( 'should dispatch events if queue is full and clear queue' , async ( ) => {
179
197
const eventDispatcher = getMockDispatcher ( ) ;
180
198
const mockDispatch : MockInstance < typeof eventDispatcher . dispatchEvent > = eventDispatcher . dispatchEvent ;
0 commit comments