Example:
val stream = if (true) {
Observable.just(Some(IOException()), None)
} else {
Observable.just(Some(RuntimeException()), None)
}
stream.filterSome() // Compile error
stream is of type Observable<out Optional<Exception>> and filterSome() (and other RxJava 2 extensions) can't be applied to such streams. Need to fix it.
Example:
streamis of typeObservable<out Optional<Exception>>andfilterSome()(and other RxJava 2 extensions) can't be applied to such streams. Need to fix it.