This is an automated email from the ASF dual-hosted git repository.
bvahdat pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new d40cf0f cleanups for camel-rxjava2 to camel-rxjava component renaming
d40cf0f is described below
commit d40cf0f1a94849923f3360f59689040a2ad7435a
Author: Babak Vahdat <[email protected]>
AuthorDate: Sun Aug 18 10:37:09 2019 +0200
cleanups for camel-rxjava2 to camel-rxjava component renaming
---
.../src/main/docs/reactive-streams-component.adoc | 4 ++--
.../component/reactive/streams/platforms/RxJavaPlatformTest.java | 2 +-
components/readme.adoc | 2 +-
docs/components/modules/ROOT/pages/reactive-streams-component.adoc | 4 ++--
4 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/components/camel-reactive-streams/src/main/docs/reactive-streams-component.adoc
b/components/camel-reactive-streams/src/main/docs/reactive-streams-component.adoc
index 01d25da..3ad2aea 100644
---
a/components/camel-reactive-streams/src/main/docs/reactive-streams-component.adoc
+++
b/components/camel-reactive-streams/src/main/docs/reactive-streams-component.adoc
@@ -200,7 +200,7 @@ CamelReactiveStreamsService camel =
CamelReactiveStreams.get(context);
// Get a stream from all the files in a directory
Publisher<String> files = camel.from("file:folder", String.class);
-// Use the stream in RxJava2
+// Use the stream in RxJava
Flowable.fromPublisher(files)
.doOnNext(System.out::println)
.subscribe();
@@ -333,7 +333,7 @@ A reactive processing step can be associated to the
"direct:reactive" endpoint:
CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);
camel.process("direct:reactive", Integer.class, items ->
- Flowable.fromPublisher(items) // RxJava2
+ Flowable.fromPublisher(items) // RxJava
.map(n -> -n)); // make every number negative
---------------------------------------------------------
diff --git
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/platforms/RxJavaPlatformTest.java
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/platforms/RxJavaPlatformTest.java
index 38f72dd..b58260a 100644
---
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/platforms/RxJavaPlatformTest.java
+++
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/platforms/RxJavaPlatformTest.java
@@ -23,7 +23,7 @@ import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber;
-public class RxJava2PlatformTest extends AbstractPlatformTestSupport {
+public class RxJavaPlatformTest extends AbstractPlatformTestSupport {
@Override
protected void changeSign(Publisher<Integer> data, Consumer<Integer>
consume) {
diff --git a/components/readme.adoc b/components/readme.adoc
index 5377476..803fa2d 100644
--- a/components/readme.adoc
+++ b/components/readme.adoc
@@ -1082,7 +1082,7 @@ Number of Miscellaneous Components: 34 in 34 JAR
artifacts (0 deprecated)
| link:camel-ribbon/src/main/docs/ribbon.adoc[Ribbon] (camel-ribbon) | 2.18 |
Using Netflix Ribbon for client side load balancing
-| link:camel-rxjava/src/main/docs/rxjava.adoc[Rxjava] (camel-rxjava) | 2.22 |
RxJava2 based back-end for Camel's reactive streams component
+| link:camel-rxjava/src/main/docs/rxjava.adoc[Rxjava] (camel-rxjava) | 2.22 |
RxJava based back-end for Camel's reactive streams component
| link:camel-shiro/src/main/docs/shiro.adoc[Shiro] (camel-shiro) | 2.5 |
Security using Shiro
diff --git a/docs/components/modules/ROOT/pages/reactive-streams-component.adoc
b/docs/components/modules/ROOT/pages/reactive-streams-component.adoc
index 01d25da..3ad2aea 100644
--- a/docs/components/modules/ROOT/pages/reactive-streams-component.adoc
+++ b/docs/components/modules/ROOT/pages/reactive-streams-component.adoc
@@ -200,7 +200,7 @@ CamelReactiveStreamsService camel =
CamelReactiveStreams.get(context);
// Get a stream from all the files in a directory
Publisher<String> files = camel.from("file:folder", String.class);
-// Use the stream in RxJava2
+// Use the stream in RxJava
Flowable.fromPublisher(files)
.doOnNext(System.out::println)
.subscribe();
@@ -333,7 +333,7 @@ A reactive processing step can be associated to the
"direct:reactive" endpoint:
CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);
camel.process("direct:reactive", Integer.class, items ->
- Flowable.fromPublisher(items) // RxJava2
+ Flowable.fromPublisher(items) // RxJava
.map(n -> -n)); // make every number negative
---------------------------------------------------------
