This might be required:
```java
subscriber.add(scheduler.schedule(...));
```
Test with slow scheduler:
```java
Subscriber<Integer> sub = Subscribers.create(...);
sub.unsubscribe();
Observable.from(1).subscribeOn(new SlowScheduler(), -1).subscribe(sub);
```
and assert no events.