Riccardo Cardin

As I discussed with Adam on X, I opened this issue because I tried integrating my library [raise4s](https://github.com/rcardin/raise4s) with Ox. First, I tried to create a custom `ErrorMode`: ```scala 3...

In many cases, it's not clear if the testing library doesn't wait the proper interval of time or if there is a problem in the application under testing. Some debugging...

You must specify the type parameter explicitly for the `consume` and `produce` methods. Take the following code as an example: ```java new SpringKafkaesque(broker) .consume() .fromTopic("test") .waitingAtMost(1L, TimeUnit.SECONDS) .waitingEmptyPolls(5, 100L, TimeUnit.MILLISECONDS)...

Embrace the Given-When-Then philosophy in the Kafkaesque API

Refactor the project to create submodules. The aim is to make it easy to add integrations with external libraries. For example, the actual code should go into the `core` module.

Add a `zipOrAccumulate` variant that accumulates on a custom type. The type must have an associated _Monoid_ type class.

Add a `mapOrAccumulate` variant that accumulates on a custom type. The type must have an associated _Monoid_ type class.

Add integration with [Ox](https://ox.softwaremill.com/latest/index.html) library. The integration should look like the following: ```scala 3 val result: (Int, String) raises Int = par(RaiseErrorMode[Int])( { sleep(200.millis) println("Lambda 1") 1 }, { sleep(100.millis)...

Embrace a more Kotlinish style, letting the `KBehavior` type be defined as follows: ```kotlin object MainActor { val behavior: KkBehavior = setup { val counterRef = ctx.spawn("counter", Counter.behavior(0)) counterRef `!`...

The `withError` function lets us use errors from different hierarchies in the same scope. See the following tweet for an example: https://x.com/riccardo_cardin/status/1783803145111351797 However, it adds a lot of complexity to...