|
1 | 1 | # RxJava Releases #
|
2 | 2 |
|
| 3 | +### Version 1.0.6 – Feburary 11th 2015 ([Maven Central](http://search.maven.org/#artifactdetails%7Cio.reactivex%7Crxjava%7C1.0.6%7C)) ### |
| 4 | + |
| 5 | +This release adds an experimental operator and fixes several bugs. |
| 6 | + |
| 7 | +##### flatMap(maxConcurrent) |
| 8 | + |
| 9 | +> Note that this API [may still change or be removed altogether](https://github.com/ReactiveX/RxJava#beta) since it is marked as `@Beta`. |
| 10 | +
|
| 11 | +A `flatMap` overload was added that allows limiting concurrency, or the number of `Observable`s being merged . |
| 12 | + |
| 13 | +This now means that these are the same, one using `merge` directly, the other using `flatMap` and passing in `10` as the `maxConcurrent`: |
| 14 | + |
| 15 | +```java |
| 16 | +Observable<Observable<Integer>> asyncWork = range(1, 1000000) |
| 17 | + .doOnNext(i -> System.out.println("Emitted Value: " + i)) |
| 18 | + .map(item -> { |
| 19 | + return just(item) |
| 20 | + .doOnNext(MergeMaxConcurrent::sleep) |
| 21 | + .subscribeOn(Schedulers.io()); |
| 22 | + }); |
| 23 | +merge(asyncWork, 10).toBlocking().forEach(v -> System.out.println("Received: " + v)); |
| 24 | +``` |
| 25 | + |
| 26 | +```java |
| 27 | +range(1, 1000000) |
| 28 | + .doOnNext(i -> System.out.println("Emitted Value: " + i)) |
| 29 | + .flatMap(item -> { |
| 30 | + return just(item) |
| 31 | + .doOnNext(MergeMaxConcurrent::sleep) |
| 32 | + .subscribeOn(Schedulers.io()); |
| 33 | + }, 10) |
| 34 | + .toBlocking().forEach(v -> System.out.println("Received: " + v)); |
| 35 | +``` |
| 36 | + |
| 37 | +#### Changes |
| 38 | + |
| 39 | +* [Pull 2627] (https://github.com/ReactiveX/RxJava/pull/2627) FlatMap overloads with maximum concurrency parameter |
| 40 | +* [Pull 2648] (https://github.com/ReactiveX/RxJava/pull/2648) TakeWhile: don't unsubscribe downstream. |
| 41 | +* [Pull 2580] (https://github.com/ReactiveX/RxJava/pull/2580) Allow configuring the maximum number of computation scheduler threads |
| 42 | +* [Pull 2601] (https://github.com/ReactiveX/RxJava/pull/2601) Added common Exceptions.throwIfAny to throw a collection of exceptions |
| 43 | +* [Pull 2644] (https://github.com/ReactiveX/RxJava/pull/2644) Missing Unsafe class yields NoClassDefFoundError |
| 44 | +* [Pull 2642] (https://github.com/ReactiveX/RxJava/pull/2642) Fix a potential memory leak in schedulePeriodically |
| 45 | +* [Pull 2630] (https://github.com/ReactiveX/RxJava/pull/2630) Cast back Observer to Subscriber if passed to subscribe(Observer) |
| 46 | +* [Pull 2622] (https://github.com/ReactiveX/RxJava/pull/2622) Changed Observable.empty() into a stateless constant observable. |
| 47 | +* [Pull 2607] (https://github.com/ReactiveX/RxJava/pull/2607) OnSubscribeRefCount - improve comments |
| 48 | + |
| 49 | + |
3 | 50 | ### Version 1.0.5 – Feburary 3rd 2015 ([Maven Central](http://search.maven.org/#artifactdetails%7Cio.reactivex%7Crxjava%7C1.0.5%7C)) ###
|
4 | 51 |
|
5 | 52 | This release includes many bug fixes along with a few new operators and enhancements.
|
|
0 commit comments