module

Crig::Concurrency

Class methods

map_ordered(items : Enumerable(A), timeout : Time::Span | Nil = nil, &block : A -> T) : Array(T) forall A, T

Run an ordered fan-out over independent inputs and join the results. This preserves input ordering while allowing each branch to execute in its own Crystal fiber.

Source
run(timeout : Time::Span | Nil = nil, &block : -> T) : Channel(Result(T)) forall T
Source

Nested types