Skip to content

Commit 7798362

Browse files
GH-2370 - Polishing.
1 parent 8956163 commit 7798362

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

src/main/java/org/springframework/data/neo4j/core/DefaultReactiveNeo4jClient.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -160,16 +160,12 @@ public RxResult run(Query query) {
160160

161161
<T> Mono<T> doInQueryRunnerForMono(Mono<DatabaseSelection> databaseSelection, Function<RxQueryRunner, Mono<T>> func) {
162162

163-
return Mono.usingWhen(retrieveRxStatementRunnerHolder(databaseSelection),
164-
func::apply,
165-
runner -> ((DelegatingQueryRunner) runner).close());
163+
return Mono.usingWhen(retrieveRxStatementRunnerHolder(databaseSelection), func, runner -> ((DelegatingQueryRunner) runner).close());
166164
}
167165

168166
<T> Flux<T> doInStatementRunnerForFlux(Mono<DatabaseSelection> databaseSelection, Function<RxQueryRunner, Flux<T>> func) {
169167

170-
return Flux.usingWhen(retrieveRxStatementRunnerHolder(databaseSelection),
171-
func::apply,
172-
runner -> ((DelegatingQueryRunner) runner).close());
168+
return Flux.usingWhen(retrieveRxStatementRunnerHolder(databaseSelection), func, runner -> ((DelegatingQueryRunner) runner).close());
173169
}
174170

175171
@Override

0 commit comments

Comments
 (0)