sync with reactor-stream package-scope change

This commit is contained in:
Stephane Maldini 2016-01-25 09:05:40 +00:00
parent a907898910
commit ac94bf1120
4 changed files with 4 additions and 6 deletions

View File

@ -29,8 +29,8 @@ import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import reactor.core.publisher.Flux;
import reactor.core.subscriber.SubscriberBarrier;
import reactor.rx.Signal;
import reactor.rx.Stream;
import reactor.rx.stream.Signal;
import static org.junit.Assert.*;

View File

@ -24,8 +24,8 @@ import org.junit.Before;
import org.junit.Test;
import org.reactivestreams.Publisher;
import reactor.core.publisher.Mono;
import reactor.rx.Signal;
import reactor.rx.Stream;
import reactor.rx.stream.Signal;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;

View File

@ -21,8 +21,8 @@ import java.util.List;
import org.junit.Before;
import org.junit.Test;
import org.reactivestreams.Publisher;
import reactor.rx.Signal;
import reactor.rx.Stream;
import reactor.rx.stream.Signal;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
@ -32,7 +32,6 @@ import org.springframework.web.ResponseStatusException;
import org.springframework.web.server.DefaultWebServerExchange;
import org.springframework.web.server.WebServerExchange;
import static junit.framework.TestCase.assertSame;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;

View File

@ -15,7 +15,6 @@
*/
package org.springframework.web.reactive.method;
import java.lang.reflect.Method;
import java.net.URI;
import java.util.Arrays;
@ -27,8 +26,8 @@ import org.junit.Test;
import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.rx.Signal;
import reactor.rx.Stream;
import reactor.rx.stream.Signal;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;