skuld_concurrency

Coroutine > | Umbrella →

Cooperative coroutines, streaming, and concurrency for the Skuld effect system.

What's included

• Skuld.Coroutine — cooperative fiber primitive with typed states
• Skuld.Effects.FiberPool — cooperative scheduler with structured concurrency
• Skuld.Effects.Channel — bounded channels with backpressure and error propagation
• Skuld.Effects.Brook — streaming combinators (map, filter, flat_map, etc.)
• Skuld.AsyncCoroutine — cross-process bridge for LiveView and GenServer
• Skuld.Effects.Task — BEAM process parallelism within FiberPool

Installation

def deps do
  [
    {:skuld_concurrency, "~> 0.32"}
  ]
end

Quick start

use Skuld.Syntax
alias Skuld.Effects.{Yield, FiberPool}

comp do
  results <- FiberPool.map(1..4, fn i ->
    comp do
      Yield.yield(i * 2)
    end
  end)
  results
end
|> Yield.with_handler()
|> FiberPool.with_handler()
|> Comp.run!()
#=> [2, 4, 6, 8]

See the architecture guide for how this fits into the Skuld ecosystem.

Coroutine > | Umbrella →