diff --git a/README.md b/README.md index 2d04278b..05927cc8 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.4" +"com.softwaremill.ox" %% "core" % "0.5.5" ``` Or [scala-cli](https://scala-cli.virtuslab.org): ```scala -//> using dep "com.softwaremill.ox::core:0.5.4" +//> using dep "com.softwaremill.ox::core:0.5.5" ``` 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/index.md b/generated-doc/out/index.md index d9d88aa7..edca44cf 100644 --- a/generated-doc/out/index.md +++ b/generated-doc/out/index.md @@ -2,7 +2,7 @@ Safe direct-style concurrency and resiliency for Scala on the JVM. Requires JDK 21 & Scala 3. -To start using Ox, add the `com.softwaremill.ox::core:0.5.4` [dependency](info/dependency.md) to your project. +To start using Ox, add the `com.softwaremill.ox::core:0.5.5` [dependency](info/dependency.md) to your project. Then, take a look at the tour of Ox, or follow one of the topics listed in the menu to get to know Ox's API! In addition to this documentation, ScalaDocs can be browsed at [https://javadoc.io](https://www.javadoc.io/doc/com.softwaremill.ox). diff --git a/generated-doc/out/info/dependency.md b/generated-doc/out/info/dependency.md index b0f99d49..8bd4479a 100644 --- a/generated-doc/out/info/dependency.md +++ b/generated-doc/out/info/dependency.md @@ -4,10 +4,10 @@ To use ox core in your project, add: ```scala // sbt dependency -"com.softwaremill.ox" %% "core" % "0.5.4" +"com.softwaremill.ox" %% "core" % "0.5.5" // scala-cli dependency -//> using dep com.softwaremill.ox::core:0.5.4 +//> using dep com.softwaremill.ox::core:0.5.5 ``` Ox core depends only on the Java [jox](https://github.com/softwaremill/jox) project, where channels are implemented. There are no other direct or transitive dependencies. diff --git a/generated-doc/out/integrations/kafka.md b/generated-doc/out/integrations/kafka.md index 3862f948..923e2e2b 100644 --- a/generated-doc/out/integrations/kafka.md +++ b/generated-doc/out/integrations/kafka.md @@ -3,7 +3,7 @@ Dependency: ```scala -"com.softwaremill.ox" %% "kafka" % "0.5.4" +"com.softwaremill.ox" %% "kafka" % "0.5.5" ``` `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/integrations/mdc-logback.md b/generated-doc/out/integrations/mdc-logback.md index 9e1d054c..1ad351bc 100644 --- a/generated-doc/out/integrations/mdc-logback.md +++ b/generated-doc/out/integrations/mdc-logback.md @@ -3,7 +3,7 @@ Dependency: ```scala -"com.softwaremill.ox" %% "mdc-logback" % "0.5.4" +"com.softwaremill.ox" %% "mdc-logback" % "0.5.5" ``` 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 650aa769..6fd095b7 100644 --- a/generated-doc/out/streaming/flows.md +++ b/generated-doc/out/streaming/flows.md @@ -112,7 +112,7 @@ Behind the scenes, an `Ox` concurrency scope is created along with a number of f Some other stages which introduce concurrency include `.merge`, `.interleave`, `.groupedWithin` and [I/O](io.md) stages. The created channels serve as buffers between the pipeline stages, and their capacity is defined by the `BufferCapacity` in scope (a default instance is available, if not provided explicitly). -Explicit asynchronous boundaries can be inserted using `.async()`. This might be useful if producing the next element to emit, and consuming the previous should run concurrently; or if the processing times of the consumer varies, and the producer should buffer up elements. +Explicit asynchronous boundaries can be inserted using `.buffer()`. This might be useful if producing the next element to emit, and consuming the previous should run concurrently; or if the processing times of the consumer varies, and the producer should buffer up elements. ## Interoperability with channels @@ -171,7 +171,7 @@ To obtain a `org.reactivestreams.Publisher` instance, you'll need to add the fol bring the `toReactiveStreamsPublisher` method into scope: ```scala -// sbt dependency: "com.softwaremill.ox" %% "flow-reactive-streams" % "0.5.4" +// sbt dependency: "com.softwaremill.ox" %% "flow-reactive-streams" % "0.5.5" import ox.supervised import ox.flow.Flow diff --git a/generated-doc/out/tour.md b/generated-doc/out/tour.md index 5a961463..4ecdda04 100644 --- a/generated-doc/out/tour.md +++ b/generated-doc/out/tour.md @@ -104,7 +104,7 @@ Flow.iterate(0)(_ + 1) // natural numbers .map(_ + 1) .intersperse(5) // compute the running total - .mapStateful(() => 0) { (state, value) => + .mapStateful(0) { (state, value) => val newState = state + value (newState, newState) }