root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Use Flux instead of Stream in Publisher based integration tests

This commit is contained in:
Sebastien Deleuze 2016-02-09 17:58:12 +01:00
parent 36788207f3
commit 628ae2fda8
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
spring-web-reactive/src/test/java/org/springframework/web/reactive/method/annotation/RequestMappingIntegrationTests.java
View File

@ -469,7 +469,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
@RequestMapping("/param") @RequestMapping("/param")
public Publisher<String> handleWithParam(@RequestParam String name) { public Publisher<String> handleWithParam(@RequestParam String name) {
return Stream.just("Hello ", name, "!"); return Flux.just("Hello ", name, "!");
} }
@RequestMapping("/person") @RequestMapping("/person")
@ -485,7 +485,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
@RequestMapping("/raw") @RequestMapping("/raw")
public Publisher<ByteBuffer> rawResponseBody() { public Publisher<ByteBuffer> rawResponseBody() {
JacksonJsonEncoder encoder = new JacksonJsonEncoder(new DefaultDataBufferAllocator()); JacksonJsonEncoder encoder = new JacksonJsonEncoder(new DefaultDataBufferAllocator());
return encoder.encode(Stream.just(new Person("Robert")), return encoder.encode(Mono.just(new Person("Robert")),
ResolvableType.forClass(Person.class), MediaType.APPLICATION_JSON).map(DataBuffer::asByteBuffer); ResolvableType.forClass(Person.class), MediaType.APPLICATION_JSON).map(DataBuffer::asByteBuffer);
} }
@ -526,7 +526,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
@RequestMapping("/publisher") @RequestMapping("/publisher")
public Publisher<Person> publisherResponseBody() { public Publisher<Person> publisherResponseBody() {
return Stream.just(new Person("Robert"), new Person("Marie")); return Flux.just(new Person("Robert"), new Person("Marie"));
} }
@RequestMapping("/flux") @RequestMapping("/flux")
@ -546,7 +546,7 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
@RequestMapping("/publisher-capitalize") @RequestMapping("/publisher-capitalize")
public Publisher<Person> publisherCapitalize(@RequestBody Publisher<Person> persons) { public Publisher<Person> publisherCapitalize(@RequestBody Publisher<Person> persons) {
return Stream return Flux
.from(persons) .from(persons)
.map(person -> new Person(person.getName().toUpperCase())); .map(person -> new Person(person.getName().toUpperCase()));
} }