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