From 7031c1c885ac4e28c928e00a526ea5b211bc6118 Mon Sep 17 00:00:00 2001 From: Dmitriy Tverdiakov Date: Thu, 27 Apr 2023 10:47:18 +0100 Subject: [PATCH] Update dependencies --- ...ReactiveResultPublisherVerificationIT.java | 23 +++++++++---------- pom.xml | 20 ++++++++-------- 2 files changed, 21 insertions(+), 22 deletions(-) diff --git a/driver/src/test/java/org/neo4j/driver/tck/reactive/ReactiveResultPublisherVerificationIT.java b/driver/src/test/java/org/neo4j/driver/tck/reactive/ReactiveResultPublisherVerificationIT.java index 0dadb7edab..db0cff2685 100644 --- a/driver/src/test/java/org/neo4j/driver/tck/reactive/ReactiveResultPublisherVerificationIT.java +++ b/driver/src/test/java/org/neo4j/driver/tck/reactive/ReactiveResultPublisherVerificationIT.java @@ -18,12 +18,12 @@ */ package org.neo4j.driver.tck.reactive; -import static reactor.adapter.JdkFlowAdapter.flowPublisherToFlux; - import java.time.Duration; +import java.util.Map; import org.neo4j.driver.Driver; -import org.neo4j.driver.reactive.ReactiveResult; -import org.neo4j.driver.reactive.ReactiveSession; +import org.neo4j.driver.Record; +import org.neo4j.driver.reactivestreams.ReactiveResult; +import org.neo4j.driver.reactivestreams.ReactiveSession; import org.reactivestreams.Publisher; import org.reactivestreams.tck.PublisherVerification; import org.reactivestreams.tck.TestEnvironment; @@ -31,7 +31,7 @@ import org.testng.annotations.BeforeClass; import reactor.core.publisher.Mono; -public class ReactiveResultPublisherVerificationIT extends PublisherVerification { +public class ReactiveResultPublisherVerificationIT extends PublisherVerification { private final Neo4jManager NEO4J = new Neo4jManager(); private static final Duration TIMEOUT = Duration.ofSeconds(10); private static final Duration TIMEOUT_FOR_NO_SIGNALS = Duration.ofSeconds(1); @@ -63,15 +63,14 @@ public long maxElementsFromPublisher() { } @Override - public Publisher createPublisher(long elements) { - ReactiveSession session = driver.session(ReactiveSession.class); - return Mono.from(flowPublisherToFlux(session.run("RETURN 1"))); + public Publisher createPublisher(long elements) { + var session = driver.session(ReactiveSession.class); + return Mono.from(session.run("UNWIND range(0, $elements) AS x RETURN x", Map.of("elements", elements - 1))) + .flatMapMany(ReactiveResult::records); } @Override - public Publisher createFailedPublisher() { - ReactiveSession session = driver.session(ReactiveSession.class); - // Please note that this publisher fails on run stage. - return Mono.from(flowPublisherToFlux(session.run("RETURN 5/0"))); + public Publisher createFailedPublisher() { + return null; } } diff --git a/pom.xml b/pom.xml index e58e03a7ab..cf994b94dc 100644 --- a/pom.xml +++ b/pom.xml @@ -36,25 +36,25 @@ - 4.1.90.Final + 4.1.92.Final - 2020.0.30 + 2022.0.6 1.7.36 2.0.0.0 - 5.2.0 - 5.9.2 + 5.3.1 + 5.9.3 1.0.4 1.2.0 1.70 - 1.4.6 - 2.14.2 + 1.4.7 + 2.15.0 1.18.26 - 22.3.1 - 1.10.5 - 1.17.6 - 5.6.0 + 22.3.2 + 1.10.6 + 1.18.0 + 5.7.0