0.0.4

Bugfixes

• PublishSubject & BehaviorSubject did not respond to certain type of cancellations (#29)

0.0.3

Bugfixes

• Ensure subject removes cancelled consumer (#17)
• Fix BehaviorSubject and ReplaySubject to remove a cancelled consumer upon job cancellation (commit 60e611ca)

Enhancements

• Add onBackpressureDrop operator (commit 3862105a)
• Add flatMapDrop operator (commit 60e611ca)

Other

• Bump kotlin_version from 1.3.60 to 1.3.61 (#12)
• Bump kotlinx-coroutines-core from 1.3.2 to 1.3.3 (#14)

0.0.2

Maven

Highlights

• Implemented a couple of Flow operators
• Added a sub-DSL for parallel Flow processing

Changes

• Sources
  • range
  • timer
• Intermediate Flow operators (FlowExtensions)
  • Flow.concatWith
  • Flow.groupBy
  • Flow.parallel
  • Flow.publish
  • Flow.replay
  • Flow.startCollectOn
  • Flow.takeUntil
• ParallelFlow operators (FlowExtensions)
  • ParallelFlow.concatMap
  • ParallelFlow.filter
  • ParallelFlow.map
  • ParallelFlow.reduce
  • ParallelFlow.sequential
  • ParallelFlow.transform

0.0.1

Maven

Initial release.

Flow-based multicasting classes

• PublishSubject (Example)
• ReplaySubject (Example)
• BehaviorSubject (Example)