Skip to content

Commit bf98f26

Browse files
chillaqchillaq
committed
updated tests
1 parent 58cb0b9 commit bf98f26

17 files changed

Lines changed: 152 additions & 98 deletions

‎spec/allocations/splitclient-rb/clients/split_client_spec.rb‎

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,16 @@
44

55
describe SplitIoClient::SplitClient do
66
let(:config) { SplitIoClient::SplitConfig.new(impressions_queue_size: 10) }
7-
7+
let(:events_queue) { Queue.new }
8+
let(:events_manager) { SplitIoClient::Engine::Events::EventsManager.new(SplitIoClient::Engine::Events::EventsManagerConfig.new,
9+
SplitIoClient::Engine::Events::EventsDelivery.new(config),
10+
config) }
811
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([])}
912
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([])}
10-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
11-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
13+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
14+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
1215
let(:impressions_repository) { SplitIoClient::Cache::Repositories::ImpressionsRepository.new(config) }
13-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
16+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
1417
let(:impression_counter) { SplitIoClient::Engine::Common::ImpressionCounter.new }
1518
let(:evaluation_producer) { SplitIoClient::Telemetry::EvaluationProducer.new(config) }
1619
let(:impression_observer) { SplitIoClient::Observers::ImpressionObserver.new }
@@ -42,7 +45,7 @@
4245
unique_keys_tracker)
4346
end
4447
let(:client) do
45-
SplitIoClient::SplitClient.new('', {:splits => splits_repository, :segments => segments_repository, :impressions => impressions_repository, :events => nil}, nil, config, impressions_manager, evaluation_producer, evaluator, SplitIoClient::Validators.new(config), fallback_treatment_calculator)
48+
SplitIoClient::SplitClient.new('', {:splits => splits_repository, :segments => segments_repository, :impressions => impressions_repository, :events => nil}, nil, config, impressions_manager, evaluation_producer, evaluator, SplitIoClient::Validators.new(config), fallback_treatment_calculator, events_manager)
4649
end
4750

4851
context 'control' do

‎spec/cache/fetchers/segment_fetch_spec.rb‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,13 @@
3131
end
3232

3333
context 'memory adapter' do
34+
let(:events_queue) { Queue.new }
3435
let(:config) { SplitIoClient::SplitConfig.new }
35-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
36+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
3637
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([]) }
3738
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
38-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
39-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
39+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
40+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
4041
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
4142
let(:segment_fetcher) { described_class.new(segments_repository, '', config, telemetry_runtime_producer) }
4243
let(:split_fetcher) do
@@ -67,13 +68,14 @@
6768
before do
6869
Redis.new.flushall
6970
end
71+
let(:events_queue) { Queue.new }
7072
let(:config) { SplitIoClient::SplitConfig.new(cache_adapter: :redis) }
7173
let(:adapter) { SplitIoClient::Cache::Adapters::RedisAdapter.new(config.redis_url) }
72-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
74+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
7375
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::RedisFlagSetsRepository.new(config) }
7476
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
75-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
76-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
77+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
78+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
7779
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
7880
let(:segment_fetcher) { described_class.new(segments_repository, '', config, telemetry_runtime_producer) }
7981
let(:split_fetcher) do

‎spec/cache/fetchers/split_fetch_spec.rb‎

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,11 @@
2323
cache_adapter: :memory
2424
)
2525
end
26+
let(:events_queue) { Queue.new }
2627
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([]) }
2728
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
28-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
29-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
29+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
30+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
3031
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
3132
let(:store) { described_class.new(splits_repository, rule_based_segments_repository, '', config, telemetry_runtime_producer) }
3233

@@ -77,10 +78,11 @@
7778
flag_sets_filter: ['set_2']
7879
)
7980
end
81+
let(:events_queue) { Queue.new }
8082
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new(['set_2']) }
8183
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new(['set_2']) }
82-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
83-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
84+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
85+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
8486
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
8587
let(:store) { described_class.new(splits_repository, rule_based_segments_repository, '', config, telemetry_runtime_producer) }
8688

@@ -131,10 +133,11 @@
131133
cache_adapter: :redis
132134
)
133135
end
136+
let(:events_queue) { Queue.new }
134137
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::RedisFlagSetsRepository.new(config) }
135138
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
136-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
137-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
139+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
140+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
138141
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
139142
let(:store) { described_class.new(splits_repository, rule_based_segments_repository, '', config, telemetry_runtime_producer) }
140143

‎spec/cache/stores/localhost_split_store_spec.rb‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,13 @@
33
require 'spec_helper'
44

55
describe SplitIoClient::Cache::Stores::LocalhostSplitStore do
6+
67
let(:log) { StringIO.new }
8+
let(:events_queue) { Queue.new }
79
let(:config) { SplitIoClient::SplitConfig.new(logger: Logger.new(log)) }
810
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([]) }
911
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
10-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
12+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
1113

1214
let(:split_file) do
1315
['local_feature local_treatment']

‎spec/engine/api/segments_spec.rb‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,13 @@
1111
)
1212
end
1313
let(:log) { StringIO.new }
14+
let(:events_queue) { Queue.new }
1415
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
1516
let(:segments_api) { described_class.new('', segments_repository, config, telemetry_runtime_producer) }
1617
let(:adapter) do
1718
SplitIoClient::Cache::Adapters::MemoryAdapter.new(SplitIoClient::Cache::Adapters::MemoryAdapters::MapAdapter.new)
1819
end
19-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
20+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
2021
let(:segments) do
2122
File.read(File.expand_path(File.join(File.dirname(__FILE__), '../../test_data/segments/segments.json')))
2223
end

‎spec/engine/matchers/rule_based_segment_matcher_spec.rb‎

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,12 @@
33
require 'spec_helper'
44

55
describe SplitIoClient::RuleBasedSegmentMatcher do
6+
let(:events_queue) { Queue.new }
67
let(:config) { SplitIoClient::SplitConfig.new(debug_enabled: true) }
7-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
8+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
89
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([])}
910
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([])}
10-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
11+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
1112

1213
context '#string_type' do
1314
it 'is not string type matcher' do
@@ -17,14 +18,14 @@
1718

1819
context 'test_matcher' do
1920
it 'return false if excluded key is passed' do
20-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
21+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
2122
rbs_repositoy.update([{name: 'foo', trafficTypeName: 'tt_name_1', conditions: [], excluded: {keys: ['key1'], segments: []}}], [], -1)
2223
matcher = described_class.new(segments_repository, rbs_repositoy, 'foo', config)
2324
expect(matcher.match?(value: 'key1')).to be false
2425
end
2526

2627
it 'return false if excluded segment is passed' do
27-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
28+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
2829
evaluator = SplitIoClient::Engine::Parser::Evaluator.new(segments_repository, splits_repository, rbs_repositoy, true)
2930
segments_repository.add_to_segment({:name => 'segment1', :added => [], :removed => []})
3031
rbs_repositoy.update([{:name => 'foo', :trafficTypeName => 'tt_name_1', :conditions => [], :excluded => {:keys => ['key1'], :segments => [{:name => 'segment1', :type => 'standard'}]}}], [], -1)
@@ -33,7 +34,7 @@
3334
end
3435

3536
it 'return false if excluded rb segment is matched' do
36-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
37+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
3738
rbs = {:name => 'sample_rule_based_segment', :trafficTypeName => 'tt_name_1', :conditions => [{
3839
:matcherGroup => {
3940
:combiner => "AND",
@@ -106,15 +107,15 @@
106107
}]
107108
}
108109

109-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
110+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
110111
rbs_repositoy.update([rule_based_segment], [], -1)
111112
matcher = described_class.new(segments_repository, rbs_repositoy, 'corge', config)
112113
expect(matcher.match?({:matching_key => 'user', :attributes => {}})).to be false
113114
expect(matcher.match?({:matching_key => 'k1', :attributes => {}})).to be true
114115
end
115116

116117
it 'return true if dependent rb segment matches' do
117-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
118+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
118119
rbs = {
119120
:changeNumber => 5,
120121
:name => "dependent_rbs",
@@ -180,7 +181,7 @@
180181
end
181182

182183
it 'return true if has multiple conditions' do
183-
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config)
184+
rbs_repositoy = SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue)
184185
rbs = {
185186
:name => 'sample_rule_based_segment',
186187
:trafficTypeName => 'tt_name_1',

‎spec/engine/parser/evaluator_spec.rb‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,11 +3,12 @@
33
require 'spec_helper'
44

55
describe SplitIoClient::Engine::Parser::Evaluator do
6-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(@default_config) }
7-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(@default_config) }
6+
let(:events_queue) { Queue.new }
7+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(@default_config, events_queue) }
8+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(@default_config, events_queue) }
89
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([])}
910
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([])}
10-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(@default_config, flag_sets_repository, flag_set_filter) }
11+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(@default_config, flag_sets_repository, flag_set_filter, events_queue) }
1112
let(:evaluator) { described_class.new(segments_repository, splits_repository, rule_based_segments_repository, true) }
1213

1314
let(:killed_split) { { killed: true, defaultTreatment: 'default' } }

‎spec/engine/push_manager_spec.rb‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,15 +6,16 @@
66
describe SplitIoClient::Engine::PushManager do
77
subject { SplitIoClient::Engine::PushManager }
88

9+
let(:events_queue) { Queue.new }
910
let(:body_response) { File.read(File.join(SplitIoClient.root, 'spec/test_data/integrations/auth_body_response.json')) }
1011
let(:api_key) { 'PushManager-key' }
1112
let(:log) { StringIO.new }
1213
let(:config) { SplitIoClient::SplitConfig.new(logger: Logger.new(log)) }
1314
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([]) }
1415
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
15-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
16-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
17-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
16+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
17+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
18+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
1819
let(:runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
1920
let(:split_fetcher) { SplitIoClient::Cache::Fetchers::SplitFetcher.new(splits_repository, rule_based_segments_repository, api_key, config, runtime_producer) }
2021
let(:segment_fetcher) { SplitIoClient::Cache::Fetchers::SegmentFetcher.new(segments_repository, api_key, config, runtime_producer) }

‎spec/engine/sync_manager_spec.rb‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
subject { SplitIoClient::Engine::SyncManager }
88

99
let(:event_control) { "d4\r\nid: 123\nevent: message\ndata: {\"id\":\"1\",\"clientId\":\"emptyClientId\",\"timestamp\": 1582056812285,\"encoding\": \"json\",\"channel\": \"control_pri\",\"data\":\"{\\\"type\\\" : \\\"CONTROL\\\",\\\"controlType\\\":\\\"STREAMING_DISABLED\\\"}\"}\n\n\r\n" }
10-
10+
let(:events_queue) { Queue.new }
1111
let(:splits) { File.read(File.join(SplitIoClient.root, 'spec/test_data/integrations/splits.json')) }
1212
let(:segment1) { File.read(File.join(SplitIoClient.root, 'spec/test_data/integrations/segment1.json')) }
1313
let(:segment2) { File.read(File.join(SplitIoClient.root, 'spec/test_data/integrations/segment2.json')) }
@@ -18,9 +18,9 @@
1818
let(:config) { SplitIoClient::SplitConfig.new(logger: Logger.new(log), streaming_enabled: true) }
1919
let(:flag_sets_repository) {SplitIoClient::Cache::Repositories::MemoryFlagSetsRepository.new([]) }
2020
let(:flag_set_filter) {SplitIoClient::Cache::Filter::FlagSetsFilter.new([]) }
21-
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter) }
22-
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config) }
23-
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config) }
21+
let(:splits_repository) { SplitIoClient::Cache::Repositories::SplitsRepository.new(config, flag_sets_repository, flag_set_filter, events_queue) }
22+
let(:segments_repository) { SplitIoClient::Cache::Repositories::SegmentsRepository.new(config, events_queue) }
23+
let(:rule_based_segments_repository) { SplitIoClient::Cache::Repositories::RuleBasedSegmentsRepository.new(config, events_queue) }
2424
let(:impressions_repository) { SplitIoClient::Cache::Repositories::ImpressionsRepository.new(config) }
2525
let(:telemetry_runtime_producer) { SplitIoClient::Telemetry::RuntimeProducer.new(config) }
2626
let(:events_repository) { SplitIoClient::Cache::Repositories::EventsRepository.new(config, api_key, telemetry_runtime_producer) }
@@ -51,7 +51,7 @@
5151
let(:telemetry_consumers) { { init: init_consumer, runtime: runtime_consumer, evaluation: evaluation_consumer } }
5252
let(:telemetry_api) { SplitIoClient::Api::TelemetryApi.new(config, api_key, telemetry_runtime_producer) }
5353
let(:telemetry_synchronizer) { SplitIoClient::Telemetry::Synchronizer.new(config, telemetry_consumers, init_producer, repositories, telemetry_api, 0, 0) }
54-
let(:status_manager) { SplitIoClient::Engine::StatusManager.new(config) }
54+
let(:status_manager) { SplitIoClient::Engine::StatusManager.new(config, events_queue) }
5555
let(:splits_worker) { SplitIoClient::SSE::Workers::SplitsWorker.new(synchronizer, config, splits_repository, telemetry_runtime_producer, sync_params[:segment_fetcher], rule_based_segments_repository) }
5656
let(:segments_worker) { SplitIoClient::SSE::Workers::SegmentsWorker.new(synchronizer, config, segments_repository) }
5757
let(:notification_processor) { SplitIoClient::SSE::NotificationProcessor.new(config, splits_worker, segments_worker) }

0 commit comments

Comments
 (0)