❗️(Potential) Breaking Changes

• SFlux. scan parameter is changed to reference value. The original SFlux.scan with by-name parameter is now renamed to SFlux.scanWith (#61)

➕Added Operators

• SFlux.foldWith this will align closer to scala collection operators, which will make SFlux.reduceWith deprecated (#61)
• SFlux.scanWith similar to SFlux.scan, but use by-name parameter (#61)
• SFlux.product to multiply all the emitted value if they're Numeric
• SMono.+ to sum the value of this SMono and another SMono if the value type is Numeric
• SMono.- to subtract the value of this SMono and another SMono if the value type is Numeric
• SMono.* to multiply the value of this SMono and another SMono if the value type is Numeric

👋 Deprecated Operators

• SFlux. reduceWith. Use SFlux.foldWith (#61)

➖ Removed Operators

• SFlux.foldLeft. This is an alias for SFlux.fold. In reactive-stream, there is only one way from front to back hence there is no concept of foldLeft or foldRight. (#61)

🐞Bug Fixed

• SFlux.asJava and SMono.asJava will return an in-variant type to retain the semantic of previous code and avoid the need to cast. (#69)

🛠️Build - Code coverage - Continuous Integration

• Compiled and tested using scala 2.12.11 for 2.12 branch
• Compiled and tested using scala 2.13.2 for 2.13 branch
• Code coverage now is 82.83%

🙏Thanks to the following contributors

• @jpork (#61)
• @rs017991 (#69 )

❗️(Potential) Breaking Changes

• SFlux and SMono element type is now declared as Covariant Type. This may or may not be breaking changes. (#54)

➕Added Operators

• SFlux.deferWithContext
• SFlux.metrics whenever there is Micrometer in classpath (#56)
• SMono.metrics whenever there is Micrometer in classpath (#56)

🐞Bug Fixed

• SFlux.toStream to use the batchSize parameter

🛠️Build - Code coverage - Continuous Integration

• Added Github Action Scala CI
• Compile and Test using multiple Java LTE versions (8, 11, 14)
• Updated sbt to 1.3.10

🙏Thanks to the following contributors

• @jpork (#54)
• @rs017991 (#56)

Added Operators

• Added SFlux.retryWhen(Retry)

Deprecated Operators

Deprecate old SFlux.retryWhen(predicate)

Breaking Changes

Renamed ConnectableFlux to ConnectableSFlux to differentiate between Java ConnectableFlux and Scala ConnectableFlux

Build - Code coverage - Continuous Integration

• Cross compile with jdk-14
• Switch build using sbt (#35)
• Added unit test for SFlux.switchOnNext
• Compile with scala 2.13.2

Documentation

• Added scaladoc for SFlux.sample
• Added scaladoc for SFlux.scan
• Added scaladoc for SFlux.startWith

Updated:

• Updated to reactor-core-3.3.3.RELEASE
• SFlux.scan works without explicitly specifying generic type (#52)
• SFlux.scanWith works without explicit generic type(#52)

New Operators:

• fold in SFlux as alias for foldLeft
• scan, reduce & zipWithCombinator in SFlux uses curry function to pass the accumulator. This replaces the previous signature where the accumulator is passed via 2nd parameter. (#52)

Removed Operators:

• scan, reduce & zipWithCombinator with accumulator as 2nd parameter. See new operator. (#52)

New Operators:

• ++ in SFlux as an alias to concatWith so it can perform SFlux.just(1) ++ SFlux.just(2,3)

What's New:

• Fixed code coverage that's not detected by codecov
• Removed dependency findbug as it is highlighted in BlackDuck scanning (#51)
• Update underlying reactor library to version 3.3.2.RELEASE

Merry Chrismas

New Operators:

• SFlux.transformDeferred to replace SFlux.compose
• SMono.transformDeffered to replace SMono.compose

Deprecated Operators:

• SFlux.compose replaced by SFlux.transformDeferred
• SMono.compose replaced by SMono.composed

What's new:

• Cross compile with Scala 2.13 #27
• Upgraded underlying reactor-core to version v3.3.1.RELEASE

Contributors:

• @giabao
• @rs017991
• @sullis