Skip to content

Commit 0ce1ce8

Browse files
committed
minor doc changes around rxjava and reactor
1 parent 69281b1 commit 0ce1ce8

3 files changed

Lines changed: 19 additions & 17 deletions

File tree

md/doc/async/async.md

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{{async.md}}
22

3-
# reactive & async modules
3+
# modules
44

55
## akka
66

@@ -10,10 +10,12 @@
1010

1111
* [executor](/doc/executor): async processing via Java ```Executors```
1212

13-
## reactive
13+
## reactor
1414

1515
* [reactor](/doc/reactor): build reactive web applications via <a href="http://projectreactor.io">reactor</a>
1616

17+
## rxjava
18+
1719
* [rx](/doc/rxjava): build reactive web applications via <a href="https://github.com/ReactiveX/RxJava">rxjava</a>
1820

1921
* [rxjdbc](/doc/rxjava-jdbc): efficient execution, concise code, and functional composition of database calls using JDBC and RxJava Observable

md/doc/reactor/reactor.md

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
## exports
1616

1717
* map route operator that converts ```Flux``` and ```Mono``` into [Deferred API]({{defdocs}}/Deferred.html).
18-
* set a default server thread pool with the number of available processors.
18+
* set a default server thread pool with the number of available processors.
1919

2020
## usage
2121

@@ -26,7 +26,7 @@ import org.jooby.reactor.Reactor;
2626
{
2727
use(new Reactor());
2828

29-
get("/", req -> Flux.just("reactive programming in jooby!"))
29+
get("/", () -> Flux.just("reactive programming in jooby!"))
3030
.map(Reactor.reactor());
3131
}
3232
```
@@ -76,7 +76,7 @@ import org.jooby.reactor.Reactor;
7676
}
7777
```
7878

79-
This is better than written N routes using the [Deferred API]({{defdocs}}/Deferred.html) route by route... but still there is one more option to help you (and your fingers) to right less code:
79+
This is better than written N routes using the [Deferred API]({{defdocs}}/Deferred.html)... but still there is one more option to help you (and your fingers) to right less code:
8080

8181
```java
8282
...
@@ -86,10 +86,10 @@ import org.jooby.reactor.Reactor;
8686
use(new Reactor());
8787

8888
with(() -> {
89-
get("/1", req -> Observable...);
90-
get("/2", req -> Observable...);
89+
get("/1", () -> Observable...);
90+
get("/2", () -> Observable...);
9191
....
92-
get("/N", req -> Observable...);
92+
get("/N", () -> Observable...);
9393
}).map(Reactor.reactor());
9494

9595
}
@@ -112,10 +112,10 @@ import org.jooby.reactor.Reactor;
112112

113113
with(() -> {
114114

115-
get("/1", req -> Observable...);
116-
get("/2", req -> Observable...);
115+
get("/1", () -> Observable...);
116+
get("/2", () -> Observable...);
117117
....
118-
get("/N", req -> Observable...);
118+
get("/N", () -> Observable...);
119119
}).map(Reactor.reactor(Computations::concurrent));
120120

121121
}

md/doc/rxjava/rxjava.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import org.jooby.rx.Rx;
2929
{
3030
use(new Rx());
3131

32-
get("/", req -> Observable.from("reactive programming in jooby!"))
32+
get("/", () -> Observable.from("reactive programming in jooby!"))
3333
.map(Rx.rx());
3434
}
3535
```
@@ -52,7 +52,7 @@ Previous example is translated to:
5252
}
5353
```
5454

55-
Translation is done with the [Rx.rx()]({{defdocs}}/rx/Rx.html#rx--) route operator. If you are a <a href="https://github.com/ReactiveX/RxJava">RxJava</a> programmer then you don't need to worry for learning a new API and semantic. The [Rx.rx()]({{defdocs}}/rx/Rx.html#rx--) route operator deal and take cares of the [Deferred API]({{defdocs}}/Deferred.html) API.
55+
Translation is done with the [Rx.rx()]({{defdocs}}/rx/Rx.html#rx--) route operator. If you are a <a href="https://github.com/ReactiveX/RxJava">RxJava</a> programmer then you don't need to worry for learning a new API and semantic. The [Rx.rx()]({{defdocs}}/rx/Rx.html#rx--) route operator deal and take cares of the [Deferred API]({{defdocs}}/Deferred.html).
5656

5757
## rx()
5858

@@ -67,19 +67,19 @@ import org.jooby.rx.Rx;
6767
{
6868
use(new Rx());
6969

70-
get("/1", req -> Observable...)
70+
get("/1", () -> Observable...)
7171
.map(Rx.rx());
7272

73-
get("/2", req -> Observable...)
73+
get("/2", () -> Observable...)
7474
.map(Rx.rx());
7575
....
7676

77-
get("/N", req -> Observable...)
77+
get("/N", () -> Observable...)
7878
.map(Rx.rx());
7979
}
8080
```
8181

82-
This is better than written N routes using the [Deferred API]({{defdocs}}/Deferred.html) route by route... but still there is one more option to help you (and your fingers) to right less code:
82+
This is better than written N routes using the [Deferred API]({{defdocs}}/Deferred.html)... but still there is one more option to help you (and your fingers) to right less code:
8383

8484
```java
8585
...

0 commit comments

Comments
 (0)