File tree Expand file tree Collapse file tree 3 files changed +1
-17
lines changed
main/java/org/neo4j/driver/internal
test/java/org/neo4j/driver/v1/integration Expand file tree Collapse file tree 3 files changed +1
-17
lines changed Original file line number Diff line number Diff line change @@ -236,7 +236,7 @@ private Throwable extractFailure()
236
236
{
237
237
if ( failure == null )
238
238
{
239
- throw new IllegalStateException ( "Can't consume failure because it does not exist" );
239
+ throw new IllegalStateException ( "Can't extract failure because it does not exist" );
240
240
}
241
241
242
242
Throwable error = failure ;
Original file line number Diff line number Diff line change 26
26
import java .util .concurrent .ExecutionException ;
27
27
import java .util .concurrent .Future ;
28
28
29
- import static java .util .concurrent .CompletableFuture .completedFuture ;
30
-
31
29
public final class Futures
32
30
{
33
31
private Futures ()
@@ -118,16 +116,4 @@ public static Throwable completionErrorCause( Throwable error )
118
116
}
119
117
return error ;
120
118
}
121
-
122
- public static <T > CompletionStage <T > firstNotNull ( CompletionStage <T > stage1 , CompletionStage <T > stage2 )
123
- {
124
- return stage1 .thenCompose ( value ->
125
- {
126
- if ( value != null )
127
- {
128
- return completedFuture ( value );
129
- }
130
- return stage2 ;
131
- } );
132
- }
133
119
}
Original file line number Diff line number Diff line change @@ -969,8 +969,6 @@ public void shouldFailToCommitWhenQueriesFailAndErrorNotConsumed() throws Interr
969
969
tx .runAsync ( "RETURN 10 / 0" );
970
970
tx .runAsync ( "CREATE (:TestNode)" );
971
971
972
- Thread .sleep ( 1000 );
973
-
974
972
try
975
973
{
976
974
getBlocking ( tx .commitAsync () );
You can’t perform that action at this time.
0 commit comments