|
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