3.x: [Java 8] Add Observable operators + cleanup by akarnokd · Pull Request #6797 · ReactiveX/RxJava (original) (raw)

Add the following Java 8 operators to Observable:

• fromOptional
• fromCompletionStage
• fromStream
• firstStage
• firstOrErrorStage
• singeStage
• singleOrErrorStage
• lastStage
• lastOrErrorStage
• blockingStream
• mapOptional
• collect
• concatMapStream / flatMapStream

In addition, some validators received reporting improvements (such as using at so the IDE can jump to the exact line of the issue). Consequently, all local variable misnaming of UnicastSubject up and UnicastProcessor us have been fixed as well.

Related #6776