diff --git a/README.md b/README.md index f82a37b9..220c5780 100644 --- a/README.md +++ b/README.md @@ -23,13 +23,13 @@ the project! To test Ox, use the following dependency, using either [sbt](https://www.scala-sbt.org): ```scala -"com.softwaremill.ox" %% "core" % "0.5.1" +"com.softwaremill.ox" %% "core" % "0.5.2" ``` Or [scala-cli](https://scala-cli.virtuslab.org): ```scala -//> using dep "com.softwaremill.ox::core:0.5.1" +//> using dep "com.softwaremill.ox::core:0.5.2" ``` Documentation is available at [https://ox.softwaremill.com](https://ox.softwaremill.com), ScalaDocs can be browsed at [https://javadoc.io](https://www.javadoc.io/doc/com.softwaremill.ox). diff --git a/generated-doc/out/basics/start-here.md b/generated-doc/out/basics/start-here.md index 521219f4..448411f4 100644 --- a/generated-doc/out/basics/start-here.md +++ b/generated-doc/out/basics/start-here.md @@ -4,10 +4,10 @@ ```scala // sbt dependency -"com.softwaremill.ox" %% "core" % "0.5.1" +"com.softwaremill.ox" %% "core" % "0.5.2" // scala-cli dependency -//> using dep com.softwaremill.ox::core:0.5.1 +//> using dep com.softwaremill.ox::core:0.5.2 ``` ## Scope of the Ox project @@ -53,6 +53,7 @@ We offer commercial support for Ox and related technologies, as well as developm * [Supervision, Kafka and Java 21: what’s new in Ox](https://softwaremill.com/supervision-kafka-and-java-21-whats-new-in-ox/) * [Designing a (yet another) retry API](https://softwaremill.com/designing-a-yet-another-retry-api/) * [Handling errors in direct-style Scala](https://softwaremill.com/handling-errors-in-direct-style-scala/) +* [Direct-style concurrent streaming](https://softwaremill.com/direct-style-concurrent-streaming/) ## Inspiration & building blocks diff --git a/generated-doc/out/kafka.md b/generated-doc/out/kafka.md index 83d1bbfe..2f6c24e9 100644 --- a/generated-doc/out/kafka.md +++ b/generated-doc/out/kafka.md @@ -3,7 +3,7 @@ Dependency: ```scala -"com.softwaremill.ox" %% "kafka" % "0.5.1" +"com.softwaremill.ox" %% "kafka" % "0.5.2" ``` `Flow`s which read from a Kafka topic, mapping stages and drains which publish to Kafka topics are available through diff --git a/generated-doc/out/mdc-logback.md b/generated-doc/out/mdc-logback.md index 94430519..c23bd021 100644 --- a/generated-doc/out/mdc-logback.md +++ b/generated-doc/out/mdc-logback.md @@ -3,7 +3,7 @@ Dependency: ```scala -"com.softwaremill.ox" %% "mdc-logback" % "0.5.1" +"com.softwaremill.ox" %% "mdc-logback" % "0.5.2" ``` Ox provides support for setting inheritable MDC (mapped diagnostic context) values, when using the [Logback](https://logback.qos.ch) diff --git a/generated-doc/out/streaming/flows.md b/generated-doc/out/streaming/flows.md index c055f976..01badc06 100644 --- a/generated-doc/out/streaming/flows.md +++ b/generated-doc/out/streaming/flows.md @@ -50,11 +50,11 @@ Flow.usingEmit: emit => if isNoon() then emit(42) ``` -The `emit: FlowEmit` instances is used to emit elements by the flow, that is process them further, as defined by the downstream pipeline. This method only completes once the element is fully processed, and it might throw exceptions in case there's a processing error. +The `emit: FlowEmit` instance is used to emit elements by the flow, that is process them further, as defined by the downstream pipeline. This method only completes once the element is fully processed, and it might throw exceptions in case there's a processing error. As part of the callback, you can create [supervision scopes](../structured-concurrency/error-handling-scopes.md), fork background computations or run other flows asynchronously. However, take care **not** to share the `emit: FlowEmit` instance across threads. That is, instances of `FlowEmit` are thread-unsafe and should only be used on the calling thread. The lifetime of `emit` should not extend over the duration of the invocation of `withEmit`. -Any asynchronous communication should be best done with [channels](channels.md). You can then manually any elements received from a channel to `emit`, or use e.g. `FlowEmit.channelToEmit`. +Any asynchronous communication should be best done with [channels](channels.md). You can then manually forward any elements received from a channel to `emit`, or use e.g. `FlowEmit.channelToEmit`. ## Transforming flows: basics