0.16.2

• New operator: FlowableTransformers.mapAsync(): map a value to the single result of a generated Publisher. (Example)
• New operator: FlowableTransformers.filterAsync(): filter based on the boolean result of a generated Publisher. (Example)

0.16.1

• New operator: FlowableTransformers.expand() to recursively expand items of Publishers. (Example)

0.16.0

• Upgrade to RxJava 2.0.7
• Fix places using RxJava internal API
• Add FlowableTransformers.flatMapSync operator with customizable collector strategy. Example
• Add FlowableTransformers.flatMapAsync operator that includes a scheduled collector with customizable collector strategy. Example
• Add FlowableTransformers.switchIfEmpty and switchIfEmptyArray that allows multiple fallback sources in case they turn out to be empty. Example

0.15.2

• Upgrade to RxJava 2.0.6
• Add assembly tracking support of ParallelFlowable to RxJavaAssemblyTracking

0.15.1

Notable changes:

• New custom scheduler: BlockingScheduler (Example).

0.15.0

• Added Flowables.intervalBackpressure(): interval with virtual buffering in case of backpressure (Example).
• Added FlowableTransformers.cacheLast(): cache and emit the very last item. (Example)
• Added FlowableTransformers.timeoutLast(): emit the latest if no new item arrives within a timeout period. (Example)
• Added FlowableTransformers.timeoutLastAbsolute(): emit the latest when the source completes or the timeout happens. (Example)
• Added FlowableTransformers.debounceFirst(): debounce variant that takes the first item in the window and then drops items until there is no item within the specified time window relative to the latest item. (Example)
• Added FlowableTransformer.switchFlatMap(): a combination of switchMap and flatMap: flattens up to a maximum number of mapped inner sources but replaces the oldest one if a newer inner source arrives beyond the active limit. (Example)

0.14.4

• Upgrade dependency to RxJava 2.0.5
• Deprecate ParallelFlowable in favor of io.reactivex.parallel.ParallelFlowable added by RxJava 2.0.5.
• Deprecate SingleSubject, MaybeSubject and CompletableSubject in favor for the same classes in io.reactivex.subjects added by RxJava 2.0.5.

0.14.3

• Upgrade to RxJava 2.0.4
• Add FlowableTransformers.bufferSplit() operator. Example
• Add plugin hooks to Flowables.repeat() and Flowables.repeatCallable()

0.14.2

• Add Flowables.repeat(T) to repeat a scalar value indefinitely
• Add Flowables.repeatCallable(Callable) to repeatedly call a callable indefinitely
• Add FlowableTransformers.every() to relay only every Nth item

0.14.1

• Add Nono.cache()
• Add Solo.cache()
• Add Perhaps.cache()