diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/userissues/UserIssuesTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/userissues/UserIssuesTests.java index 3a53b07c2..02b395e2a 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/userissues/UserIssuesTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/userissues/UserIssuesTests.java @@ -16,30 +16,24 @@ package org.springframework.cloud.function.userissues; -import java.lang.reflect.Type; import java.util.ArrayList; import java.util.List; import java.util.function.Function; import org.junit.Before; import org.junit.Test; +import reactor.core.publisher.Flux; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.cloud.function.context.FunctionCatalog; -import org.springframework.cloud.function.context.catalog.FunctionTypeUtils; -import org.springframework.cloud.function.json.JsonMapper; import org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry.FunctionInvocationWrapper; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; -import org.springframework.core.ResolvableType; import org.springframework.messaging.Message; -import org.springframework.messaging.converter.AbstractMessageConverter; import org.springframework.messaging.support.GenericMessage; -import reactor.core.publisher.Flux; - import static org.assertj.core.api.Assertions.assertThat; /** @@ -108,8 +102,8 @@ public class UserIssuesTests { FunctionCatalog catalog = this.configureCatalog(Issue601Configuration.class); FunctionInvocationWrapper function = catalog.lookup("uppercase"); System.out.println(function.getFunctionType().getTypeName()); - assertThat(function.getFunctionType().getTypeName()) - .isEqualTo("java.util.function.Function, reactor.core.publisher.Flux>"); + assertThat(function.getFunctionType().getTypeName()).isEqualTo( + "java.util.function.Function, reactor.core.publisher.Flux>"); Flux result = (Flux) function.apply(Flux.just("julien", "ricky", "bubbles")); List results = result.collectList().block(); assertThat(results.get(0)).isEqualTo(6); @@ -117,7 +111,6 @@ public class UserIssuesTests { assertThat(results.get(2)).isEqualTo(7); } - @EnableAutoConfiguration @Configuration public static class Issue602Configuration { @@ -137,17 +130,17 @@ public class UserIssuesTests { @Configuration public static class Issue601Configuration { @Bean - public Uppercase uppercase() { - return new Uppercase(); - } + public Uppercase uppercase() { + return new Uppercase(); + } } public static class Uppercase implements Function, Flux> { - @Override - public Flux apply(Flux s) { - return s.map(v -> v.length()); - } + @Override + public Flux apply(Flux s) { + return s.map(v -> v.length()); + } } public static class Product {