v0.0.22

What’s Changed

• Add support for application errors (#95) @adamw
• Update embedded-kafka to 3.7.0 (#94) @softwaremill-ci
• Update logback-classic to 1.5.3 (#93) @softwaremill-ci
• Update logback-classic to 1.5.2 (#92) @softwaremill-ci
• Update scala3-library to 3.3.3 (#91) @softwaremill-ci
• Update logback-classic to 1.5.1 (#88) @softwaremill-ci
• Update sbt-softwaremill-common, ... to 2.0.20 (#89) @softwaremill-ci
• Update jox:core to 0.1.1 (#87) @softwaremill-ci

v0.0.21

What’s Changed

• Add safe & unsafe (throwing) methods variants to channels & selects (#86) @adamw
• Update sbt-softwaremill-common, ... to 2.0.19 (#84) @softwaremill-ci
• Fix the tick source to emit values at regular intervals, accommodating for slow consumers (#82) @adamw
• Update sbt to 1.9.9 (#80) @softwaremill-ci
• Change default channel capacity to 16. Add companion methods to create channels (#81) @adamw
• Update pekko-stream to 1.0.2 (#79) @softwaremill-ci
• Properly wait for Kafka to commit messages, documentation, manual tests (#78) @adamw
• Update kafka-clients to 3.6.1 (#76) @softwaremill-ci
• Update logback-classic to 1.5.0 (#75) @softwaremill-ci

v0.0.20

What’s Changed

• Update scalatest to 3.2.18 (#73) @softwaremill-ci
• Update logback-classic to 1.4.14 (#68) @softwaremill-ci
• Update sbt-softwaremill-common, ... to 2.0.18 (#69) @softwaremill-ci
• Update embedded-kafka to 3.6.1 (#70) @softwaremill-ci
• Update kafka-clients to 3.5.2 (#71) @softwaremill-ci
• Update slf4j-api to 2.0.12 (#74) @softwaremill-ci
• Update scalafmt-core to 3.7.17 (#72) @softwaremill-ci
• Compiled documentation (#67) @adamw

v0.0.19

What’s Changed

• Change fork->forkUser, forkDaemon->fork (#66) @adamw
• Update jox to 0.1.0 (#65) @adamw

Breaking changes

The fork method is renamed to forkUser, and forkDaemon to fork. This is motivated by the fact that most forks are daemon threads, with the main logic happening in the scope body - after the body completes, any pending non-daemon forks are probably a bug. Hence the defaults have changed, and now the default fork is a daemon one, and a fork which needs to finish before a scope ends has a special name: forkUser.

v0.0.18

What’s Changed

• Update jox to 0.0.7 (#64) @adamw

v0.0.17

What’s Changed

• Use jox for channels (#63) @adamw

v0.0.16

What’s Changed

• Retries (#49) @rucek

v0.0.15

What’s Changed

• collectPar, filterPar, foreachPar for collections added (#54) @amorfis
• mapPar for collections (#52) @amorfis
• Parse test reports in the GH Actions workflow (#53) @amorfis
• Fix self-suppressed exceptions (#51) @adamw
• Improve exception handling (#50) @adamw
• feat: implement Source.futureSource operator (#33) @geminicaprograms
• feat: implement orElse operator (#47) @geminicaprograms
• feat: implement Source.future operator (#32) @geminicaprograms
• Unify error handling (#29) @rucek
• feat: introduce takeLast(n) operator (#31) @geminicaprograms
• feat: implement reduce operator (#30) @geminicaprograms
• feat: implement fold operator (#27) @geminicaprograms
• chore: apply comments from #27 to existing code in SourceOps.scala (#28) @geminicaprograms
• feat: implement last and lastOption operators (#26) @geminicaprograms
• feat: implement throttle function (#24) @geminicaprograms
• feat: implement head and headOption operators (#25) @geminicaprograms
• Don't rethrow exceptions in mapParUnordered (#23) @rucek
• feat: implement takeWhile function (#22) @geminicaprograms
• feat: introduce intersperse function (#18) @geminicaprograms
• feat: implement drop function (#20) @geminicaprograms
• Add Source.mapStateful and Source.mapStatefulConcat combinators (#15) @rucek
• feat: introduce zipAll function (#19) @geminicaprograms
• Add Source.mapParUnordered combinator (#17) @rucek
• Fix formatting in SourceOps (#16) @rucek
• Extract some Source test cases to separate classes (#14) @rucek
• Add Source.interleaveAll combinator (#13) @rucek
• Add Source.interleave combinator (#12) @rucek
• Fix supervised/scoped code example (#11) @efemelar
• Fix useInScope example (#10) @efemelar

v0.0.14

What’s Changed

• in readme, specify that it's for Scala 3 (#9) @SethTisue

v0.0.13

What’s Changed

• No changes