| @@ -1,5 +1,5 @@ |
|
|
| 1 |
1 |
/* |
| 2 |
|
- * Copyright 2002-2021 the original author or authors. |
|
2 |
+ * Copyright 2002-2022 the original author or authors. |
| 3 |
3 |
* |
| 4 |
4 |
* Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 |
5 |
* you may not use this file except in compliance with the License. |
| @@ -24,6 +24,7 @@ import kotlinx.coroutines.flow.Flow |
|
|
| 24 |
24 |
import kotlinx.coroutines.flow.flow |
| 25 |
25 |
import org.assertj.core.api.Assertions.assertThat |
| 26 |
26 |
import org.assertj.core.api.Assertions.assertThatExceptionOfType |
|
27 |
+import org.junit.jupiter.api.Assumptions.assumeFalse |
| 27 |
28 |
import org.springframework.context.ApplicationContext |
| 28 |
29 |
import org.springframework.context.annotation.AnnotationConfigApplicationContext |
| 29 |
30 |
import org.springframework.context.annotation.ComponentScan |
| @@ -36,6 +37,7 @@ import org.springframework.web.bind.annotation.RestController |
|
|
| 36 |
37 |
import org.springframework.web.client.HttpServerErrorException |
| 37 |
38 |
import org.springframework.web.reactive.config.EnableWebFlux |
| 38 |
39 |
import org.springframework.web.testfixture.http.server.reactive.bootstrap.HttpServer |
|
40 |
+import org.springframework.web.testfixture.http.server.reactive.bootstrap.UndertowHttpServer |
| 39 |
41 |
import reactor.core.publisher.Flux |
| 40 |
42 |
import java.time.Duration |
| 41 |
43 |
|
| @@ -114,6 +116,8 @@ class CoroutinesIntegrationTests : AbstractRequestMappingIntegrationTests() { |
|
|
| 114 |
116 |
|
| 115 |
117 |
@ParameterizedHttpServerTest |
| 116 |
118 |
fun `Suspending handler method returning ResponseEntity of Flux `(httpServer: HttpServer) { |
|
119 |
+ assumeFalse(httpServer is UndertowHttpServer, "Undertow currently fails") |
|
120 |
+ |
| 117 |
121 |
startServer(httpServer) |
| 118 |
122 |
|
| 119 |
123 |
val entity = performGet<String>("/entity-flux", HttpHeaders.EMPTY, String::class.java) |