Skip to content

Commit 7826567

Browse files
igor-suhorukovjhoeller
authored andcommitted
Polish: lamdbas containing only one statement should not nest this statement in a block
1 parent 99662bc commit 7826567

File tree

5 files changed

+8
-22
lines changed

5 files changed

+8
-22
lines changed

spring-context/src/main/java/org/springframework/cache/interceptor/CacheAspectSupport.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -347,9 +347,7 @@ private Object execute(final CacheOperationInvoker invoker, Method method, Cache
347347
Object key = generateKey(context, CacheOperationExpressionEvaluator.NO_RESULT);
348348
Cache cache = context.getCaches().iterator().next();
349349
try {
350-
return wrapCacheValue(method, cache.get(key, () -> {
351-
return unwrapReturnValue(invokeOperation(invoker));
352-
}));
350+
return wrapCacheValue(method, cache.get(key, () -> unwrapReturnValue(invokeOperation(invoker))));
353351
}
354352
catch (Cache.ValueRetrievalException ex) {
355353
// The invoker wraps any Throwable in a ThrowableWrapper instance so we

spring-jms/src/main/java/org/springframework/jms/core/JmsTemplate.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -653,16 +653,12 @@ public void convertAndSend(Object message) throws JmsException {
653653

654654
@Override
655655
public void convertAndSend(Destination destination, final Object message) throws JmsException {
656-
send(destination, session -> {
657-
return getRequiredMessageConverter().toMessage(message, session);
658-
});
656+
send(destination, session -> getRequiredMessageConverter().toMessage(message, session));
659657
}
660658

661659
@Override
662660
public void convertAndSend(String destinationName, final Object message) throws JmsException {
663-
send(destinationName, session -> {
664-
return getRequiredMessageConverter().toMessage(message, session);
665-
});
661+
send(destinationName, session -> getRequiredMessageConverter().toMessage(message, session));
666662
}
667663

668664
@Override
@@ -742,9 +738,7 @@ public Message receiveSelected(String messageSelector) throws JmsException {
742738
@Override
743739
@Nullable
744740
public Message receiveSelected(final Destination destination, @Nullable final String messageSelector) throws JmsException {
745-
return execute(session -> {
746-
return doReceive(session, destination, messageSelector);
747-
}, true);
741+
return execute(session -> doReceive(session, destination, messageSelector), true);
748742
}
749743

750744
@Override

spring-web/src/main/java/org/springframework/http/codec/xml/XmlEventDecoder.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,7 @@ public Flux<XMLEvent> decode(Publisher<DataBuffer> inputStream, ResolvableType e
110110
InputStream is = dataBuffer.asInputStream();
111111
Iterator eventReader = inputFactory.createXMLEventReader(is);
112112
return Flux.fromIterable((Iterable<XMLEvent>) () -> eventReader)
113-
.doFinally(t -> {
114-
DataBufferUtils.release(dataBuffer);
115-
});
113+
.doFinally(t -> DataBufferUtils.release(dataBuffer));
116114
}
117115
catch (XMLStreamException ex) {
118116
return Mono.error(ex);

spring-webflux/src/main/java/org/springframework/web/reactive/function/client/ExchangeFilterFunctions.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,10 +91,8 @@ private static ExchangeFilterFunction basicAuthenticationInternal(
9191
clientRequest -> credentialsFunction.apply(clientRequest).map(
9292
credentials -> {
9393
ClientRequest authorizedRequest = ClientRequest.from(clientRequest)
94-
.headers(headers -> {
95-
headers.set(HttpHeaders.AUTHORIZATION,
96-
authorization(credentials));
97-
})
94+
.headers(headers -> headers.set(HttpHeaders.AUTHORIZATION,
95+
authorization(credentials)))
9896
.build();
9997
return Mono.just(authorizedRequest);
10098
})

spring-webflux/src/main/java/org/springframework/web/reactive/function/server/support/RouterFunctionMapping.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -114,9 +114,7 @@ protected void initRouterFunctions() {
114114

115115
List<RouterFunction<?>> routerFunctions = routerFunctions();
116116
if (!CollectionUtils.isEmpty(routerFunctions) && logger.isInfoEnabled()) {
117-
routerFunctions.forEach(routerFunction -> {
118-
logger.info("Mapped " + routerFunction);
119-
});
117+
routerFunctions.forEach(routerFunction -> logger.info("Mapped " + routerFunction));
120118
}
121119
this.routerFunction = routerFunctions.stream()
122120
.reduce(RouterFunction::andOther)

0 commit comments

Comments
 (0)