Deprecating RxJava components in the reactive module

Resolves #1317
Resolves #1320
This commit is contained in:
Soby Chacko
2018-03-21 11:05:55 -04:00
committed by Oleg Zhurakousky
parent 4a9806a1b1
commit 9556fc5ffc
4 changed files with 12 additions and 0 deletions

View File

@@ -28,6 +28,9 @@ import org.springframework.util.Assert;
/**
* Adapts an {@link org.springframework.cloud.stream.annotation.Input} annotated
* {@link MessageChannel} to an {@link Observable}.
*
* @deprecated as of 2.0.0.RELEASE, this is deprecated and will be removed in 2.1 Use Project Reactor based alternatives offered in Spring Cloud Stream.
*
* @author Marius Bogoevici
*/
public class MessageChannelToInputObservableParameterAdapter

View File

@@ -31,8 +31,12 @@ import org.springframework.util.Assert;
/**
* Adapts an {@link org.springframework.cloud.stream.annotation.Output} annotated
* {@link ObservableSender} to an outbound {@link MessageChannel}.
*
* @deprecated as of 2.0.0.RELEASE, this is deprecated and will be removed in 2.1 Use Project Reactor based alternatives offered in Spring Cloud Stream.
*
* @author Marius Bogoevici
*/
@Deprecated
public class MessageChannelToObservableSenderParameterAdapter implements
StreamListenerParameterAdapter<ObservableSender, MessageChannel> {

View File

@@ -23,8 +23,11 @@ import rx.Single;
* Used for {@link org.springframework.cloud.stream.annotation.StreamListener} arguments
* annotated with {@link org.springframework.cloud.stream.annotation.Output}.
*
* @deprecated as of 2.0.0.RELEASE, this interface is deprecated and will be removed in 2.1 Use Project Reactor based {@link FluxSender}.
*
* @author Marius Bogoevici
*/
@Deprecated
public interface ObservableSender {
/**

View File

@@ -31,7 +31,9 @@ import org.springframework.util.Assert;
* {@link MessageChannel}.
*
* @author Marius Bogoevici
* @deprecated as of 2.0.0.RELEASE, this is deprecated and will be removed in 2.1 Use Project Reactor based alternatives offered in Spring Cloud Stream.
*/
@Deprecated
public class ObservableToMessageChannelResultAdapter
implements StreamListenerResultAdapter<Observable<?>, MessageChannel> {