diff --git a/spring-cloud-stream-core-docs/pom.xml b/spring-cloud-stream-core-docs/pom.xml index d146b57b2..65d916a16 100644 --- a/spring-cloud-stream-core-docs/pom.xml +++ b/spring-cloud-stream-core-docs/pom.xml @@ -17,10 +17,6 @@ org.springframework.cloud spring-cloud-stream - - org.springframework.cloud - spring-cloud-stream-rxjava - diff --git a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc index ec75efbd3..0cd620c08 100644 --- a/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc +++ b/spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc @@ -687,7 +687,6 @@ The programming model with reactive APIs is declarative, where instead of specif Spring Cloud Stream supports the following reactive APIs: * Reactor -* RxJava 1.x In the future, it is intended to support a more generic model based on Reactive Streams. @@ -759,43 +758,6 @@ public static class UppercaseTransformer { } ---- -===== RxJava 1.x support - -RxJava 1.x handlers follow the same rules as Reactor-based one, but will use `Observable` and `ObservableSender` arguments and return types. - -So the first example above will become: - -[source, java] ----- -@EnableBinding(Processor.class) -@EnableAutoConfiguration -public static class UppercaseTransformer { - - @StreamListener - @Output(Processor.OUTPUT) - public Observable receive(@Input(Processor.INPUT) Observable input) { - return input.map(s -> s.toUpperCase()); - } -} ----- - -The second example above will become: - - -[source, java] ----- -@EnableBinding(Processor.class) -@EnableAutoConfiguration -public static class UppercaseTransformer { - - @StreamListener - public void receive(@Input(Processor.INPUT) Observable input, - @Output(Processor.OUTPUT) ObservableSender output) { - output.send(input.map(s -> s.toUpperCase())); - } -} ----- - ===== Reactive Sources Spring Cloud Stream reactive support also provides the ability for creating reactive sources through the StreamEmitter annotation.