Skip to content

Commit f487ce9

Browse files
GH-2370 - Polishing.
1 parent 14734c3 commit f487ce9

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

+2-6
Original file line numberDiff line numberDiff line change
@@ -159,16 +159,12 @@ public RxResult run(Query query) {
159159

160160
<T> Mono<T> doInQueryRunnerForMono(final String targetDatabase, Function<RxQueryRunner, Mono<T>> func) {
161161

162-
return Mono.usingWhen(retrieveRxStatementRunnerHolder(targetDatabase),
163-
func::apply,
164-
runner -> ((DelegatingQueryRunner) runner).close());
162+
return Mono.usingWhen(retrieveRxStatementRunnerHolder(targetDatabase), func, runner -> ((DelegatingQueryRunner) runner).close());
165163
}
166164

167165
<T> Flux<T> doInStatementRunnerForFlux(final String targetDatabase, Function<RxQueryRunner, Flux<T>> func) {
168166

169-
return Flux.usingWhen(retrieveRxStatementRunnerHolder(targetDatabase),
170-
func::apply,
171-
runner -> ((DelegatingQueryRunner) runner).close());
167+
return Flux.usingWhen(retrieveRxStatementRunnerHolder(targetDatabase), func, runner -> ((DelegatingQueryRunner) runner).close());
172168
}
173169

174170
@Override

0 commit comments

Comments
 (0)