Skip to content

Commit 8e95853

Browse files
committed
feat: rebase and fixing rxjava3 tests
1 parent 419f89a commit 8e95853

File tree

3 files changed

+3
-24
lines changed

3 files changed

+3
-24
lines changed

client-reactive/src/test/java/com/influxdb/client/reactive/QueryReactiveApiTest.java

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

2929
import com.influxdb.test.AbstractMockServerTest;
3030

31-
import io.reactivex.Flowable;
31+
import io.reactivex.rxjava3.core.Flowable;
3232
import org.assertj.core.api.Assertions;
3333
import org.junit.jupiter.api.AfterEach;
3434
import org.junit.jupiter.api.BeforeEach;

client/pom.xml

Lines changed: 1 addition & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@
129129

130130
<dependency>
131131
<groupId>com.squareup.retrofit2</groupId>
132-
<artifactId>adapter-rxjava2</artifactId>
132+
<artifactId>adapter-rxjava3</artifactId>
133133
<exclusions>
134134
<exclusion>
135135
<groupId>com.squareup.okhttp3</groupId>
@@ -166,25 +166,6 @@
166166
<artifactId>converter-gson</artifactId>
167167
</dependency>
168168

169-
<dependency>
170-
<groupId>com.squareup.retrofit2</groupId>
171-
<artifactId>adapter-rxjava3</artifactId>
172-
<exclusions>
173-
<exclusion>
174-
<groupId>com.squareup.okhttp3</groupId>
175-
<artifactId>okhttp</artifactId>
176-
</exclusion>
177-
<exclusion>
178-
<groupId>com.squareup.retrofit2</groupId>
179-
<artifactId>retrofit</artifactId>
180-
</exclusion>
181-
<exclusion>
182-
<groupId>io.reactivex.rxjava2</groupId>
183-
<artifactId>rxjava</artifactId>
184-
</exclusion>
185-
</exclusions>
186-
</dependency>
187-
188169
<dependency>
189170
<groupId>com.moandjiezana.toml</groupId>
190171
<artifactId>toml4j</artifactId>

client/src/main/java/com/influxdb/client/internal/InfluxDBClientImpl.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
*/
2222
package com.influxdb.client.internal;
2323

24-
import java.util.Collections;
2524
import java.util.logging.Level;
2625
import java.util.logging.Logger;
2726
import javax.annotation.Nonnull;
@@ -82,7 +81,6 @@
8281

8382
import org.jetbrains.annotations.NotNull;
8483
import retrofit2.Call;
85-
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
8684

8785
/**
8886
* @author Jakub Bednar (bednar@github) (11/10/2018 09:36)
@@ -97,7 +95,7 @@ public final class InfluxDBClientImpl extends AbstractInfluxDBClient implements
9795

9896
public InfluxDBClientImpl(@Nonnull final InfluxDBClientOptions options) {
9997

100-
super(options, "java", Collections.singletonList(RxJava2CallAdapterFactory.create()));
98+
super(options, "java");
10199

102100
setupService = retrofit.create(SetupService.class);
103101
readyService = retrofit.create(ReadyService.class);

0 commit comments

Comments
 (0)