Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add streaming test, commented due to issue with a tomcat and jetty

Browse Source
This commit is contained in:
Stephane Maldini
2016-01-14 03:59:15 +00:00
parent 0f432f735a
commit 1e28dee608
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -23,6 +23,7 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import reactor.Flux; import reactor.Flux;
@@ -64,6 +65,7 @@ import org.springframework.web.reactive.DispatcherHandler;
import org.springframework.web.reactive.handler.SimpleHandlerResultHandler; import org.springframework.web.reactive.handler.SimpleHandlerResultHandler;
import org.springframework.web.server.WebToHttpHandlerBuilder; import org.springframework.web.server.WebToHttpHandlerBuilder;
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
/** /**
@@ -160,6 +162,19 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
assertEquals("Recovered from error: Boo", response.getBody()); assertEquals("Recovered from error: Boo", response.getBody());
} }
@Test
@Ignore
//FIXME Fail with Jetty and Tomcat
public void streamResult() throws Exception {
RestTemplate restTemplate = new RestTemplate();
URI url = new URI("http://localhost:" + port + "/stream-result");
RequestEntity<Void> request = RequestEntity.get(url).build();
ResponseEntity<String[]> response = restTemplate.exchange(request, String[].class);
assertArrayEquals(new String[]{"0", "1", "2", "3", "4"}, response.getBody());
}
@Test @Test
public void serializeAsPojo() throws Exception { public void serializeAsPojo() throws Exception {
serializeAsPojo("http://localhost:" + port + "/person"); serializeAsPojo("http://localhost:" + port + "/person");
@@ -421,6 +436,12 @@ public class RequestMappingIntegrationTests extends AbstractHttpHandlerIntegrati
ResolvableType.forClass(Person.class), MediaType.APPLICATION_JSON); ResolvableType.forClass(Person.class), MediaType.APPLICATION_JSON);
} }
@RequestMapping("/stream-result")
@ResponseBody
public Publisher<String> stringStreamResponseBody() {
return Flux.interval(1).map(Object::toString).as(Stream::from).take(5);
}
@RequestMapping("/raw-flux") @RequestMapping("/raw-flux")
@ResponseBody @ResponseBody
public Flux<ByteBuffer> rawFluxResponseBody() { public Flux<ByteBuffer> rawFluxResponseBody() {