Polishing

This commit is contained in:
Juergen Hoeller
2026-03-28 11:12:28 +01:00
parent 529a6fc932
commit b81a63fb5c
4 changed files with 3 additions and 9 deletions
@@ -822,6 +822,7 @@ public class MethodParameter {
* @since 5.0
*/
public static MethodParameter forParameter(Parameter parameter) {
Assert.notNull(parameter, "Parameter must not be null");
return forExecutable(parameter.getDeclaringExecutable(), findParameterIndex(parameter));
}
@@ -324,8 +324,7 @@ public class SimpleAsyncTaskExecutor extends CustomizableThreadCreator
catch (Throwable ex) {
// Release concurrency permit if thread creation fails
this.concurrencyThrottle.afterAccess();
throw new TaskRejectedException(
"Failed to start execution thread for task: " + task, ex);
throw new TaskRejectedException("Failed to start execution thread for task: " + task, ex);
}
}
else if (this.activeThreads != null) {
@@ -42,7 +42,6 @@ import org.springframework.util.Assert;
* @see java.util.concurrent.ExecutorService
* @see java.util.concurrent.Executors
*/
@SuppressWarnings("deprecation")
public class TaskExecutorAdapter implements AsyncTaskExecutor {
private final Executor concurrentExecutor;
@@ -105,7 +105,6 @@ final class SseServerResponse extends AbstractServerResponse {
private static final byte[] NL_NL = new byte[]{'\n', '\n'};
private final ServerHttpResponse outputMessage;
private final DeferredResult<?> deferredResult;
@@ -118,7 +117,6 @@ final class SseServerResponse extends AbstractServerResponse {
private boolean sendFailed;
public DefaultSseBuilder(HttpServletResponse response, Context context, DeferredResult<?> deferredResult,
HttpHeaders httpHeaders) {
this.outputMessage = new ServletServerHttpResponse(response);
@@ -184,7 +182,6 @@ final class SseServerResponse extends AbstractServerResponse {
@Override
public void data(Object object) throws IOException {
Assert.notNull(object, "Object must not be null");
if (object instanceof String text) {
writeString(text);
}
@@ -206,7 +203,6 @@ final class SseServerResponse extends AbstractServerResponse {
this.builder.append("data:");
try {
this.outputMessage.getBody().write(builderBytes());
Class<?> dataClass = data.getClass();
for (HttpMessageConverter<?> converter : this.messageConverters) {
if (converter.canWrite(dataClass, MediaType.APPLICATION_JSON)) {
@@ -291,8 +287,7 @@ final class SseServerResponse extends AbstractServerResponse {
public HttpHeaders getHeaders() {
return this.mutableHeaders;
}
}
}
}