Skip to content

Commit 6385051

Browse files
committed
Release 1.2.2
1 parent c65b3db commit 6385051

File tree

4 files changed

+45
-5
lines changed

4 files changed

+45
-5
lines changed

CHANGES.md

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,47 @@
11
# RxJava Releases #
22

3+
### Version 1.2.2 - November 3, 2016 ([Maven](http://search.maven.org/#artifactdetails%7Cio.reactivex%7Crxjava%7C1.2.2%7C))
4+
5+
Note that the interface `Cancellable` has been moved to `rx.functions` affecting `CompletableEmitter` and the experimental `Observable.fromEmitter(Action1<AsyncEmitter<T>> emitter, AsyncEmitter.BackpressureMode backpressure)` has been removed.
6+
7+
Another important clarification was added to the javadoc about using `SingleSubscriber`: due to the internal enhancements of `Single`, a `SingleSubscriber` is no longer wrapped into a `Subscriber`+`SafeSubscriber` which setup used to call `unsubscribe` on the `SingleSubscriber` yielding `isUnsubscribed() == true` when the source terminated. Therefore, when one extends the class `SingleSubscriber`, the `unsubscribe()` should be called manually to yield the given expecation mentioned before:
8+
9+
``` java
10+
Subscritpion s = Single.just(1).subscribe(new SingleSubscriber<Integer>() {
11+
@Override public void onSuccess(Integer t) {
12+
System.out.println("Success");
13+
unsubscribe();
14+
}
15+
16+
@Override public void onError(Throwable e) {
17+
e.printStackTrace();
18+
unsubscribe();
19+
}
20+
});
21+
22+
assertTrue(s.isUnsubscribed());
23+
```
24+
#### Documentation enhancements
25+
26+
- [Pull 4693](https://github.com/ReactiveX/RxJava/pull/4693): improve `timer` javadoc
27+
- [Pull 4769](https://github.com/ReactiveX/RxJava/pull/4769): Add note to `SingleSubscriber` doc about unsubscribe invocation in `onSuccess` and `onError`.
28+
29+
#### API enhancements
30+
31+
- [Pull 4725](https://github.com/ReactiveX/RxJava/pull/4725): remove `AsyncEmitter` deprecations
32+
- [Pull 4757](https://github.com/ReactiveX/RxJava/pull/4757): Add `cache()` to `Single`
33+
34+
#### Performance enhancements
35+
36+
- [Pull 4676](https://github.com/ReactiveX/RxJava/pull/4676): Make identity function a singleton.
37+
- [Pull 4764](https://github.com/ReactiveX/RxJava/pull/4764): `zip` - check local boolean before volatile in boolean and
38+
39+
#### Bugfixes
40+
41+
- [Pull 4716](https://github.com/ReactiveX/RxJava/pull/4716): fix`subscribe(Action1 [, Action1])` to report `isUnsubscribed` true after the callbacks were invoked
42+
- [Pull 4740](https://github.com/ReactiveX/RxJava/pull/4740): Error when tracking exception with unknown cause
43+
- [Pull 4791](https://github.com/ReactiveX/RxJava/pull/4791): Add null check to `Observable.switchIfEmpty`
44+
345
### Version 1.2.1 - October 5, 2016 ([Maven](http://search.maven.org/#artifactdetails%7Cio.reactivex%7Crxjava%7C1.2.1%7C))
446

547
#### API enhancements

src/main/java/rx/Completable.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -540,7 +540,6 @@ public void call(rx.CompletableSubscriber s) {
540540
* @return the new Completable instance
541541
* @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number)
542542
*/
543-
@SuppressWarnings("deprecation")
544543
@Experimental
545544
public static Completable fromEmitter(Action1<CompletableEmitter> producer) {
546545
return create(new CompletableFromEmitter(producer));

src/test/java/rx/internal/operators/CompletableFromEmitterTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import rx.observers.TestSubscriber;
3030
import rx.subscriptions.BooleanSubscription;
3131

32-
@SuppressWarnings("deprecation")
3332
public class CompletableFromEmitterTest {
3433

3534
@Test

src/test/java/rx/plugins/RxJavaHooksTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,12 +21,10 @@
2121
import java.lang.reflect.Method;
2222
import java.util.*;
2323
import java.util.concurrent.CountDownLatch;
24-
import java.util.concurrent.atomic.AtomicInteger;
24+
import java.util.concurrent.atomic.*;
2525

26-
import java.util.concurrent.atomic.AtomicReference;
2726
import org.junit.Test;
2827

29-
import org.mockito.Mockito;
3028
import rx.*;
3129
import rx.Observable;
3230
import rx.Scheduler.Worker;
@@ -42,6 +40,8 @@
4240
public class RxJavaHooksTest {
4341

4442
public static class TestExceptionWithUnknownCause extends RuntimeException {
43+
private static final long serialVersionUID = 6771158999860253299L;
44+
4545
TestExceptionWithUnknownCause() {
4646
super((Throwable) null);
4747
}

0 commit comments

Comments
 (0)