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

Minor updates

Browse Source
This commit is contained in:
Ilayaperumal Gopinathan
2016-05-03 15:15:24 +05:30
parent 39cf1e272d
commit 2c40db0cd8
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -554,7 +554,7 @@ Each configuration can be used for running a separate component, but in this cas
[source,java]
----
@SpringBootApplication
public class DoubleApplication {
public class SampleAggregateApplication {
public static void main(String[] args) {
new AggregateApplicationBuilder()
@@ -583,7 +583,7 @@ public interface RxJavaProcessor<I, O> {
}
----
An implementation of `RxJavaProcessor` will receive as input an `Observable` that represents the flow of inbound message payloads.
An implementation of `RxJavaProcessor` will receive `Observable` as an input that represents the flow of inbound message payloads.
The `process` method is invoked once at startup for setting up the data flow.
You can enable the use of RxJava-based processors and use them in your processor application by using the `@EnableRxJavaProcessor` annotation.