SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removing RxJava docs from core spring cloud stream docs

Browse Source
This commit is contained in:
Soby Chacko
2018-02-23 12:09:54 -05:00
parent 11dd2392b1
commit 388345e2f5
2 changed files with 0 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-core-docs/pom.xml
View File

@@ -17,10 +17,6 @@
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-rxjava</artifactId>
</dependency>
</dependencies>
<profiles>
<profile>

38
spring-cloud-stream-core-docs/src/main/asciidoc/spring-cloud-stream-overview.adoc
View File

@@ -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<String> receive(@Input(Processor.INPUT) Observable<String> 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<String> 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.