class SplitIoClient::SSE::Workers::SegmentsWorker

def initialize(synchronizer, config, segments_repository)
  @synchronizer = synchronizer
  @config = config
  @segments_repository = segments_repository
  @queue = Queue.new
  @running = Concurrent::AtomicBoolean.new(false)
end