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:
stream
is of typeObservable<out Optional<Exception>>
andfilterSome()
(and other RxJava 2 extensions) can't be applied to such streams. Need to fix it.