Skip to content

Commit baaf479

Browse files
author
Zhen
committed
Fix after review
1 parent 30797ec commit baaf479

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

driver/src/test/java/org/neo4j/driver/internal/async/pool/NettyChannelTrackerTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ public void shouldDecreaseIdleWhenClosedOutsidePool() throws Throwable
120120
assertEquals( 0, tracker.idleChannelCount( address ) );
121121

122122
// When closed before session.close
123-
channel.close();
123+
channel.close().sync();
124124

125125
// Then
126126
assertEquals( 1, tracker.inUseChannelCount( address ) );
@@ -145,7 +145,7 @@ public void shouldDecreaseIdleWhenClosedInsidePool() throws Throwable
145145
assertEquals( 1, tracker.idleChannelCount( address ) );
146146

147147
// When closed before acquire
148-
channel.close();
148+
channel.close().sync();
149149
// Then
150150
assertEquals( 0, tracker.inUseChannelCount( address ) );
151151
assertEquals( 0, tracker.idleChannelCount( address ) );

0 commit comments

Comments
 (0)