Skip to content

Commit c8a1ea4

Browse files
committed
Removes unused import
1 parent b5f5ff6 commit c8a1ea4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

spring-cloud-gateway-server-webmvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/Bucket4jFilterFunctions.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@
3333
import org.springframework.core.task.TaskExecutor;
3434
import org.springframework.http.HttpStatus;
3535
import org.springframework.http.HttpStatusCode;
36-
import org.springframework.scheduling.TaskScheduler;
3736
import org.springframework.util.Assert;
3837
import org.springframework.util.StringUtils;
3938
import org.springframework.web.servlet.function.HandlerFilterFunction;
@@ -79,9 +78,10 @@ public static HandlerFilterFunction<ServerResponse, ServerResponse> rateLimit(
7978
// TODO: configurable empty key status code
8079
return ServerResponse.status(HttpStatus.FORBIDDEN).build();
8180
}
82-
TaskExecutor taskExecutor = MvcUtils.getApplicationContext(request).getBean(APPLICATION_TASK_EXECUTOR_BEAN_NAME, TaskExecutor.class);
81+
TaskExecutor taskExecutor = MvcUtils.getApplicationContext(request)
82+
.getBean(APPLICATION_TASK_EXECUTOR_BEAN_NAME, TaskExecutor.class);
8383
Supplier<CompletableFuture<BucketConfiguration>> configSupplier = () -> CompletableFuture
84-
.supplyAsync(bucketConfigurationSupplier, taskExecutor);
84+
.supplyAsync(bucketConfigurationSupplier, taskExecutor);
8585
AsyncBucketProxy bucket = proxyManager.builder().build(key, configSupplier);
8686
CompletableFuture<ConsumptionProbe> bucketFuture = bucket.tryConsumeAndReturnRemaining(config.getTokens());
8787
ConsumptionProbe consumptionProbe;

0 commit comments

Comments
 (0)