From 53b76e90fc5b3ad954439241ee85acd8209c5fca Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Tue, 19 Jan 2016 19:57:34 +0000 Subject: [PATCH] move BackpressureUtils to subscription --- .../core/codec/support/AbstractRawByteStreamDecoder.java | 2 +- .../springframework/core/codec/support/JsonObjectEncoder.java | 2 +- .../http/server/reactive/UndertowHttpHandlerAdapter.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/AbstractRawByteStreamDecoder.java b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/AbstractRawByteStreamDecoder.java index fa20ce0c19..da49c6a983 100644 --- a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/AbstractRawByteStreamDecoder.java +++ b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/AbstractRawByteStreamDecoder.java @@ -24,7 +24,7 @@ import org.reactivestreams.Publisher; import org.reactivestreams.Subscriber; import reactor.Flux; import reactor.core.subscriber.SubscriberBarrier; -import reactor.core.support.BackpressureUtils; +import reactor.core.subscription.BackpressureUtils; import org.springframework.core.ResolvableType; import org.springframework.core.codec.Decoder; diff --git a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java index 9b8f09e910..c39639f700 100644 --- a/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java +++ b/spring-web-reactive/src/main/java/org/springframework/core/codec/support/JsonObjectEncoder.java @@ -26,7 +26,7 @@ import org.reactivestreams.Subscriber; import reactor.Flux; import reactor.Mono; import reactor.core.subscriber.SubscriberBarrier; -import reactor.core.support.BackpressureUtils; +import reactor.core.subscription.BackpressureUtils; import reactor.io.buffer.Buffer; import org.springframework.core.ResolvableType; diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java index 4682592a51..090caf179e 100644 --- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java +++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/UndertowHttpHandlerAdapter.java @@ -37,7 +37,7 @@ import org.xnio.channels.StreamSinkChannel; import org.xnio.channels.StreamSourceChannel; import reactor.Mono; import reactor.core.subscriber.BaseSubscriber; -import reactor.core.support.BackpressureUtils; +import reactor.core.subscription.BackpressureUtils; import reactor.core.support.Exceptions; import org.springframework.util.Assert;