@@ -58,7 +58,7 @@ public final class DefaultEventProcessor implements Closeable, EventProcessor {
5858 private final AtomicBoolean closed = new AtomicBoolean (false );
5959 private final Object stateLock = new Object ();
6060 private ScheduledFuture <?> eventFlushTask ;
61- private ScheduledFuture <?> contextKeysFlushTask ;
61+ private ScheduledFuture <?> contextFlushTask ;
6262 private ScheduledFuture <?> periodicDiagnosticEventTask ;
6363 private volatile boolean inputCapacityExceeded = false ;
6464 private final LDLogger logger ;
@@ -101,9 +101,9 @@ public DefaultEventProcessor(
101101 // Decide whether to start scheduled tasks that depend on the background/offline state.
102102 updateScheduledTasks (eventsConfig .initiallyInBackground , eventsConfig .initiallyOffline );
103103
104- // The context keys flush task should always be scheduled, if a contextDeduplicator exists.
104+ // The context flush task should always be scheduled, if a contextDeduplicator exists.
105105 if (eventsConfig .contextDeduplicator != null && eventsConfig .contextDeduplicator .getFlushInterval () != null ) {
106- contextKeysFlushTask = enableOrDisableTask (true , null ,
106+ contextFlushTask = enableOrDisableTask (true , null ,
107107 eventsConfig .contextDeduplicator .getFlushInterval ().longValue (), MessageType .FLUSH_USERS );
108108 }
109109 }
@@ -155,7 +155,7 @@ public void close() throws IOException {
155155 if (closed .compareAndSet (false , true )) {
156156 synchronized (stateLock ) {
157157 eventFlushTask = enableOrDisableTask (false , eventFlushTask , 0 , null );
158- contextKeysFlushTask = enableOrDisableTask (false , contextKeysFlushTask , 0 , null );
158+ contextFlushTask = enableOrDisableTask (false , contextFlushTask , 0 , null );
159159 periodicDiagnosticEventTask = enableOrDisableTask (false , periodicDiagnosticEventTask , 0 , null );
160160 }
161161 postMessageAsync (MessageType .FLUSH , null );
0 commit comments