SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix styles

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-11-09 19:42:43 +01:00
parent a38d46b593
commit 746ce3fbce
1 changed files with 10 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/userissues/UserIssuesTests.java
View File

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