@ -22,7 +22,6 @@ import org.junit.Test;
@@ -22,7 +22,6 @@ import org.junit.Test;
import org.junit.rules.ExpectedException ;
import org.junit.rules.TemporaryFolder ;
import reactor.core.publisher.Mono ;
import reactor.test.StepVerifier ;
import org.springframework.boot.testsupport.rule.OutputCapture ;
import org.springframework.boot.web.server.WebServer ;
@ -33,7 +32,6 @@ import org.springframework.http.server.reactive.ServerHttpRequest;
@@ -33,7 +32,6 @@ import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse ;
import org.springframework.util.SocketUtils ;
import org.springframework.web.reactive.function.BodyInserters ;
import org.springframework.web.reactive.function.client.ClientResponse ;
import org.springframework.web.reactive.function.client.WebClient ;
import static org.assertj.core.api.Assertions.assertThat ;
@ -70,23 +68,6 @@ public abstract class AbstractReactiveWebServerFactoryTests {
@@ -70,23 +68,6 @@ public abstract class AbstractReactiveWebServerFactoryTests {
protected abstract AbstractReactiveWebServerFactory getFactory ( ) ;
@Test
public void startStopServer ( ) {
this . webServer = getFactory ( ) . getWebServer ( new EchoHandler ( ) ) ;
this . webServer . start ( ) ;
assertThat ( this . output . toString ( ) ) . contains ( "started on port" ) ;
Mono < String > result = getWebClient ( ) . post ( ) . uri ( "/test" )
. contentType ( MediaType . TEXT_PLAIN )
. body ( BodyInserters . fromObject ( "Hello World" ) ) . exchange ( )
. flatMap ( ( response ) - > response . bodyToMono ( String . class ) ) ;
assertThat ( result . block ( ) ) . isEqualTo ( "Hello World" ) ;
this . webServer . stop ( ) ;
Mono < ClientResponse > response = getWebClient ( ) . post ( ) . uri ( "/test" )
. contentType ( MediaType . TEXT_PLAIN )
. body ( BodyInserters . fromObject ( "Hello World" ) ) . exchange ( ) ;
StepVerifier . create ( response ) . expectError ( ) . verify ( ) ;
}
@Test
public void specificPort ( ) throws Exception {
AbstractReactiveWebServerFactory factory = getFactory ( ) ;