Skip to content

Commit

Permalink
Update readme.md
Browse files Browse the repository at this point in the history
  • Loading branch information
johnmcclean authored Oct 20, 2016
1 parent 8962590 commit 7f503a4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cyclops-reactor/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ import static com.aol.cyclops.reactor.FluxTs.fluxT;
FluxTSeq<Integer> nested = fluxT(Flux.just(Flux.just(1,2,3),Flux.just(10,20,30)));
FluxTSeq<Integer> mapped = nested.map(i->i*3);

//mapped = [Flux[ReactiveSeq[3,6,9],ReactiveSeq[30,60,90]]
//mapped = [Flux[Flux[3,6,9],Flux[30,60,90]]
```
## MonoT monad transformer

Expand All @@ -220,6 +220,6 @@ import static com.aol.cyclops.reactor.MonoTs.monoT;
MonoTSeq<Integer> nestedFuture = monoT(Flux.just(Mono.just(1),Mono.just(10)));
mapped = nested.map(i->i*3);

//mapped = [Flux[FutureW[3],FutureW[30]]
//mapped = [Flux[Mono[3],Mono[30]]
```

0 comments on commit 7f503a4

Please sign in to comment.