@@ -46,7 +46,7 @@ def __eq__(self, other):
46
46
return self .__dict__ == other .__dict__
47
47
48
48
49
- class TestEventDispatcher (object ):
49
+ class CustomEventDispatcher (object ):
50
50
51
51
IMPRESSION_EVENT_NAME = 'campaign_activated'
52
52
@@ -146,7 +146,7 @@ def _set_event_processor(self, event_dispatcher, logger):
146
146
)
147
147
148
148
def test_drain_on_stop (self ):
149
- event_dispatcher = TestEventDispatcher ()
149
+ event_dispatcher = CustomEventDispatcher ()
150
150
151
151
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
152
152
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -161,7 +161,7 @@ def test_drain_on_stop(self):
161
161
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
162
162
163
163
def test_flush_on_max_timeout (self ):
164
- event_dispatcher = TestEventDispatcher ()
164
+ event_dispatcher = CustomEventDispatcher ()
165
165
166
166
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
167
167
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -176,7 +176,7 @@ def test_flush_on_max_timeout(self):
176
176
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
177
177
178
178
def test_flush_once_max_timeout (self ):
179
- event_dispatcher = TestEventDispatcher ()
179
+ event_dispatcher = CustomEventDispatcher ()
180
180
181
181
self .optimizely .logger = NoOpLogger ()
182
182
@@ -199,7 +199,7 @@ def test_flush_once_max_timeout(self):
199
199
self .optimizely .logger = NoOpLogger ()
200
200
201
201
def test_flush_max_batch_size (self ):
202
- event_dispatcher = TestEventDispatcher ()
202
+ event_dispatcher = CustomEventDispatcher ()
203
203
204
204
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
205
205
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -215,7 +215,7 @@ def test_flush_max_batch_size(self):
215
215
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
216
216
217
217
def test_flush (self ):
218
- event_dispatcher = TestEventDispatcher ()
218
+ event_dispatcher = CustomEventDispatcher ()
219
219
220
220
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
221
221
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -235,7 +235,7 @@ def test_flush(self):
235
235
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
236
236
237
237
def test_flush_on_mismatch_revision (self ):
238
- event_dispatcher = TestEventDispatcher ()
238
+ event_dispatcher = CustomEventDispatcher ()
239
239
240
240
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
241
241
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -260,7 +260,7 @@ def test_flush_on_mismatch_revision(self):
260
260
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
261
261
262
262
def test_flush_on_mismatch_project_id (self ):
263
- event_dispatcher = TestEventDispatcher ()
263
+ event_dispatcher = CustomEventDispatcher ()
264
264
265
265
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
266
266
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -285,7 +285,7 @@ def test_flush_on_mismatch_project_id(self):
285
285
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
286
286
287
287
def test_stop_and_start (self ):
288
- event_dispatcher = TestEventDispatcher ()
288
+ event_dispatcher = CustomEventDispatcher ()
289
289
290
290
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
291
291
self ._set_event_processor (event_dispatcher , mock_config_logging )
@@ -311,7 +311,7 @@ def test_stop_and_start(self):
311
311
self .assertEqual (0 , self .event_processor .event_queue .qsize ())
312
312
313
313
def test_init__invalid_batch_size (self ):
314
- event_dispatcher = TestEventDispatcher ()
314
+ event_dispatcher = CustomEventDispatcher ()
315
315
316
316
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
317
317
self .event_processor = BatchEventProcessor (
@@ -329,7 +329,7 @@ def test_init__invalid_batch_size(self):
329
329
mock_config_logging .info .assert_called_with ('Using default value 10 for batch_size.' )
330
330
331
331
def test_init__NaN_batch_size (self ):
332
- event_dispatcher = TestEventDispatcher ()
332
+ event_dispatcher = CustomEventDispatcher ()
333
333
334
334
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
335
335
self .event_processor = BatchEventProcessor (
@@ -347,7 +347,7 @@ def test_init__NaN_batch_size(self):
347
347
mock_config_logging .info .assert_called_with ('Using default value 10 for batch_size.' )
348
348
349
349
def test_init__invalid_flush_interval (self ):
350
- event_dispatcher = TestEventDispatcher ()
350
+ event_dispatcher = CustomEventDispatcher ()
351
351
352
352
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
353
353
self .event_processor = BatchEventProcessor (
@@ -365,7 +365,7 @@ def test_init__invalid_flush_interval(self):
365
365
mock_config_logging .info .assert_called_with ('Using default value 30 for flush_interval.' )
366
366
367
367
def test_init__float_flush_interval (self ):
368
- event_dispatcher = TestEventDispatcher ()
368
+ event_dispatcher = CustomEventDispatcher ()
369
369
370
370
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
371
371
self .event_processor = BatchEventProcessor (
@@ -382,7 +382,7 @@ def test_init__float_flush_interval(self):
382
382
self .assertEqual (datetime .timedelta (seconds = 0.5 ), self .event_processor .flush_interval )
383
383
384
384
def test_init__float_flush_deadline (self ):
385
- event_dispatcher = TestEventDispatcher ()
385
+ event_dispatcher = CustomEventDispatcher ()
386
386
387
387
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
388
388
self .event_processor = BatchEventProcessor (
@@ -399,7 +399,7 @@ def test_init__float_flush_deadline(self):
399
399
self .assertTrue (isinstance (self .event_processor .flushing_interval_deadline , float ))
400
400
401
401
def test_init__bool_flush_interval (self ):
402
- event_dispatcher = TestEventDispatcher ()
402
+ event_dispatcher = CustomEventDispatcher ()
403
403
404
404
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
405
405
self .event_processor = BatchEventProcessor (
@@ -417,7 +417,7 @@ def test_init__bool_flush_interval(self):
417
417
mock_config_logging .info .assert_called_with ('Using default value 30 for flush_interval.' )
418
418
419
419
def test_init__string_flush_interval (self ):
420
- event_dispatcher = TestEventDispatcher ()
420
+ event_dispatcher = CustomEventDispatcher ()
421
421
422
422
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
423
423
self .event_processor = BatchEventProcessor (
@@ -435,7 +435,7 @@ def test_init__string_flush_interval(self):
435
435
mock_config_logging .info .assert_called_with ('Using default value 30 for flush_interval.' )
436
436
437
437
def test_init__invalid_timeout_interval (self ):
438
- event_dispatcher = TestEventDispatcher ()
438
+ event_dispatcher = CustomEventDispatcher ()
439
439
440
440
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
441
441
self .event_processor = BatchEventProcessor (
@@ -453,7 +453,7 @@ def test_init__invalid_timeout_interval(self):
453
453
mock_config_logging .info .assert_called_with ('Using default value 5 for timeout_interval.' )
454
454
455
455
def test_init__NaN_timeout_interval (self ):
456
- event_dispatcher = TestEventDispatcher ()
456
+ event_dispatcher = CustomEventDispatcher ()
457
457
458
458
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
459
459
self .event_processor = BatchEventProcessor (
@@ -495,7 +495,7 @@ def on_log_event(log_event):
495
495
)
496
496
497
497
498
- class TestForwardingEventDispatcher (object ):
498
+ class CustomForwardingEventDispatcher (object ):
499
499
def __init__ (self , is_updated = False ):
500
500
self .is_updated = is_updated
501
501
@@ -512,7 +512,7 @@ def setUp(self, *args, **kwargs):
512
512
self .event_name = 'test_event'
513
513
self .optimizely .logger = NoOpLogger ()
514
514
self .notification_center = self .optimizely .notification_center
515
- self .event_dispatcher = TestForwardingEventDispatcher (is_updated = False )
515
+ self .event_dispatcher = CustomForwardingEventDispatcher (is_updated = False )
516
516
517
517
with mock .patch .object (self .optimizely , 'logger' ) as mock_config_logging :
518
518
self .event_processor = ForwardingEventProcessor (
0 commit comments