Skip to content

Commit 7031c1c

Browse files
committed
Update dependencies
1 parent d715914 commit 7031c1c

File tree

2 files changed

+21
-22
lines changed

2 files changed

+21
-22
lines changed

driver/src/test/java/org/neo4j/driver/tck/reactive/ReactiveResultPublisherVerificationIT.java

Lines changed: 11 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -18,20 +18,20 @@
1818
*/
1919
package org.neo4j.driver.tck.reactive;
2020

21-
import static reactor.adapter.JdkFlowAdapter.flowPublisherToFlux;
22-
2321
import java.time.Duration;
22+
import java.util.Map;
2423
import org.neo4j.driver.Driver;
25-
import org.neo4j.driver.reactive.ReactiveResult;
26-
import org.neo4j.driver.reactive.ReactiveSession;
24+
import org.neo4j.driver.Record;
25+
import org.neo4j.driver.reactivestreams.ReactiveResult;
26+
import org.neo4j.driver.reactivestreams.ReactiveSession;
2727
import org.reactivestreams.Publisher;
2828
import org.reactivestreams.tck.PublisherVerification;
2929
import org.reactivestreams.tck.TestEnvironment;
3030
import org.testng.annotations.AfterClass;
3131
import org.testng.annotations.BeforeClass;
3232
import reactor.core.publisher.Mono;
3333

34-
public class ReactiveResultPublisherVerificationIT extends PublisherVerification<ReactiveResult> {
34+
public class ReactiveResultPublisherVerificationIT extends PublisherVerification<Record> {
3535
private final Neo4jManager NEO4J = new Neo4jManager();
3636
private static final Duration TIMEOUT = Duration.ofSeconds(10);
3737
private static final Duration TIMEOUT_FOR_NO_SIGNALS = Duration.ofSeconds(1);
@@ -63,15 +63,14 @@ public long maxElementsFromPublisher() {
6363
}
6464

6565
@Override
66-
public Publisher<ReactiveResult> createPublisher(long elements) {
67-
ReactiveSession session = driver.session(ReactiveSession.class);
68-
return Mono.from(flowPublisherToFlux(session.run("RETURN 1")));
66+
public Publisher<Record> createPublisher(long elements) {
67+
var session = driver.session(ReactiveSession.class);
68+
return Mono.from(session.run("UNWIND range(0, $elements) AS x RETURN x", Map.of("elements", elements - 1)))
69+
.flatMapMany(ReactiveResult::records);
6970
}
7071

7172
@Override
72-
public Publisher<ReactiveResult> createFailedPublisher() {
73-
ReactiveSession session = driver.session(ReactiveSession.class);
74-
// Please note that this publisher fails on run stage.
75-
return Mono.from(flowPublisherToFlux(session.run("RETURN 5/0")));
73+
public Publisher<Record> createFailedPublisher() {
74+
return null;
7675
}
7776
}

pom.xml

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -36,25 +36,25 @@
3636
<!-- Please note that when updating this dependency -->
3737
<!-- (i.e. due to a security vulnerability or bug) that the -->
3838
<!-- corresponding server dependency also needs updating.-->
39-
<netty-bom.version>4.1.90.Final</netty-bom.version>
39+
<netty-bom.version>4.1.92.Final</netty-bom.version>
4040
<!-- Please note that when updating this dependency -->
4141
<!-- (i.e. due to a security vulnerability or bug) that the -->
4242
<!-- corresponding server dependency also needs updating.-->
43-
<reactor-bom.version>2020.0.30</reactor-bom.version>
43+
<reactor-bom.version>2022.0.6</reactor-bom.version>
4444
<slf4j-api.version>1.7.36</slf4j-api.version>
4545
<hamcrest-junit.version>2.0.0.0</hamcrest-junit.version>
46-
<mockito-core.version>5.2.0</mockito-core.version>
47-
<junit.version>5.9.2</junit.version>
46+
<mockito-core.version>5.3.1</mockito-core.version>
47+
<junit.version>5.9.3</junit.version>
4848
<testng-engine.version>1.0.4</testng-engine.version>
4949
<jarchivelib.version>1.2.0</jarchivelib.version>
5050
<bouncycastle-jdk15on.version>1.70</bouncycastle-jdk15on.version>
51-
<logback-classic.version>1.4.6</logback-classic.version>
52-
<jackson.version>2.14.2</jackson.version>
51+
<logback-classic.version>1.4.7</logback-classic.version>
52+
<jackson.version>2.15.0</jackson.version>
5353
<lombok.version>1.18.26</lombok.version>
54-
<svm.version>22.3.1</svm.version>
55-
<micrometer.version>1.10.5</micrometer.version>
56-
<testcontainers.version>1.17.6</testcontainers.version>
57-
<build-resources.version>5.6.0</build-resources.version>
54+
<svm.version>22.3.2</svm.version>
55+
<micrometer.version>1.10.6</micrometer.version>
56+
<testcontainers.version>1.18.0</testcontainers.version>
57+
<build-resources.version>5.7.0</build-resources.version>
5858
<!-- To be overwritten by child projects -->
5959
<moduleName/>
6060
</properties>

0 commit comments

Comments
 (0)