|
36 | 36 | import java.util.concurrent.TimeUnit; |
37 | 37 | import java.util.concurrent.atomic.AtomicBoolean; |
38 | 38 | import java.util.concurrent.atomic.AtomicInteger; |
39 | | -import java.util.function.Function; |
40 | 39 |
|
41 | 40 | import org.neo4j.driver.AccessMode; |
42 | 41 | import org.neo4j.driver.AuthToken; |
|
92 | 91 | import static org.neo4j.driver.util.StubServer.insecureBuilder; |
93 | 92 | import static org.neo4j.driver.util.TestUtil.asOrderedSet; |
94 | 93 |
|
95 | | -class RoutingDriverBoltKitTest |
| 94 | +class RoutingDriverBoltKitIT |
96 | 95 | { |
97 | 96 | private static StubServerController stubController; |
98 | 97 |
|
@@ -568,7 +567,7 @@ void shouldHandleLeaderSwitchAndRetryWhenWritingInTxFunction() throws IOExceptio |
568 | 567 | catch ( InterruptedException ex ) |
569 | 568 | { |
570 | 569 | } |
571 | | - return tx.run( "MATCH (n) RETURN n.name" ).list( RoutingDriverBoltKitTest::extractNameField ); |
| 570 | + return tx.run( "MATCH (n) RETURN n.name" ).list( RoutingDriverBoltKitIT::extractNameField ); |
572 | 571 | } ); |
573 | 572 | } |
574 | 573 |
|
@@ -604,7 +603,7 @@ void shouldHandleLeaderSwitchAndRetryWhenWritingInTxFunctionAsync() throws IOExc |
604 | 603 | } |
605 | 604 | return tx.runAsync( "MATCH (n) RETURN n.name" ); |
606 | 605 | } ) |
607 | | - .thenComposeAsync( cursor -> cursor.listAsync( RoutingDriverBoltKitTest::extractNameField ) ) ) ); |
| 606 | + .thenComposeAsync( cursor -> cursor.listAsync( RoutingDriverBoltKitIT::extractNameField ) ) ) ); |
608 | 607 |
|
609 | 608 | assertEquals( asList( "Foo", "Bar" ), names ); |
610 | 609 |
|
@@ -639,7 +638,7 @@ void shouldHandleLeaderSwitchAndRetryWhenWritingInTxFunctionRX() throws IOExcept |
639 | 638 | { |
640 | 639 | RxResult result = tx.run( "RETURN 1" ); |
641 | 640 | return Flux.from( result.records() ).limitRate( 100 ).thenMany( tx.run( "MATCH (n) RETURN n.name" ).records() ).limitRate( 100 ).map( |
642 | | - RoutingDriverBoltKitTest::extractNameField ); |
| 641 | + RoutingDriverBoltKitIT::extractNameField ); |
643 | 642 | } ), RxSession::close ); |
644 | 643 |
|
645 | 644 | StepVerifier.create( fluxOfNames ).expectNext( "Foo", "Bar" ).verifyComplete(); |
@@ -1255,7 +1254,7 @@ void shouldUseResolverDuringRediscoveryWhenExistingRoutersFail() throws Exceptio |
1255 | 1254 | assertEquals( asList( "Alice", "Bob", "Eve" ), names1 ); |
1256 | 1255 |
|
1257 | 1256 | // run second query with retries, it should rediscover using 9042 returned by the resolver and read from 9005 |
1258 | | - List<String> names2 = session.readTransaction( tx -> tx.run( "MATCH (n) RETURN n.name" ).list( RoutingDriverBoltKitTest::extractNameField ) ); |
| 1257 | + List<String> names2 = session.readTransaction( tx -> tx.run( "MATCH (n) RETURN n.name" ).list( RoutingDriverBoltKitIT::extractNameField ) ); |
1259 | 1258 | assertEquals( asList( "Bob", "Alice", "Tina" ), names2 ); |
1260 | 1259 | } |
1261 | 1260 | } |
|
0 commit comments