Skip to content

Commit 22aefdd

Browse files
committed
Use interable async queue from internal.
1 parent 797c07c commit 22aefdd

File tree

6 files changed

+7
-7
lines changed

6 files changed

+7
-7
lines changed

lib/sdk/server/build.gradle

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,8 @@ ext.versions = [
7070
"gson": "2.13.1",
7171
"guava": "32.0.1-jre",
7272
"jackson": "2.11.2",
73-
"launchdarklyJavaSdkCommon": "2.2.1",
74-
"launchdarklyJavaSdkInternal": "1.6.1",
73+
"launchdarklyJavaSdkCommon": "2.3.0",
74+
"launchdarklyJavaSdkInternal": "1.7.0",
7575
"launchdarklyLogging": "1.1.0",
7676
"okhttp": "4.12.0", // specify this for the SDK build instead of relying on the transitive dependency from okhttp-eventsource
7777
"okhttpEventsource": "4.2.0",

lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/DataSourceSynchronizerAdapter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.launchdarkly.sdk.server;
22

3-
import com.launchdarkly.sdk.collections.IterableAsyncQueue;
3+
import com.launchdarkly.sdk.internal.collections.IterableAsyncQueue;
44
import com.launchdarkly.sdk.internal.fdv2.sources.Selector;
55
import com.launchdarkly.sdk.server.datasources.FDv2SourceResult;
66
import com.launchdarkly.sdk.server.datasources.Synchronizer;

lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/PollingSynchronizerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.launchdarkly.sdk.server;
22

33
import com.launchdarkly.logging.LDLogger;
4-
import com.launchdarkly.sdk.collections.IterableAsyncQueue;
4+
import com.launchdarkly.sdk.internal.collections.IterableAsyncQueue;
55
import com.launchdarkly.sdk.server.datasources.FDv2SourceResult;
66
import com.launchdarkly.sdk.server.datasources.SelectorSource;
77
import com.launchdarkly.sdk.server.datasources.Synchronizer;

lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/StreamingSynchronizerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
import com.launchdarkly.eventsource.StreamHttpErrorException;
1313
import com.launchdarkly.logging.LDLogger;
1414
import com.launchdarkly.logging.LogValues;
15-
import com.launchdarkly.sdk.collections.IterableAsyncQueue;
15+
import com.launchdarkly.sdk.internal.collections.IterableAsyncQueue;
1616
import com.launchdarkly.sdk.internal.fdv2.payloads.FDv2Event;
1717
import com.launchdarkly.sdk.internal.fdv2.sources.FDv2ProtocolHandler;
1818
import com.launchdarkly.sdk.internal.fdv2.sources.Selector;

lib/sdk/server/src/main/java/com/launchdarkly/sdk/server/integrations/FileSynchronizer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.launchdarkly.logging.LDLogger;
44
import com.launchdarkly.logging.LogValues;
5-
import com.launchdarkly.sdk.collections.IterableAsyncQueue;
5+
import com.launchdarkly.sdk.internal.collections.IterableAsyncQueue;
66
import com.launchdarkly.sdk.server.datasources.FDv2SourceResult;
77
import com.launchdarkly.sdk.server.datasources.Synchronizer;
88
import com.launchdarkly.sdk.server.integrations.FileDataSourceBuilder.SourceInfo;

lib/sdk/server/src/test/java/com/launchdarkly/sdk/server/FDv2DataSourceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.google.common.collect.ImmutableList;
44
import com.launchdarkly.logging.LDLogger;
55
import com.launchdarkly.logging.Logs;
6-
import com.launchdarkly.sdk.collections.IterableAsyncQueue;
6+
import com.launchdarkly.sdk.internal.collections.IterableAsyncQueue;
77
import com.launchdarkly.sdk.internal.fdv2.sources.Selector;
88
import com.launchdarkly.sdk.server.datasources.FDv2SourceResult;
99
import com.launchdarkly.sdk.server.datasources.Initializer;

0 commit comments

Comments
 (0)