~/bend-docscommunity

bend-kit-concurrency@0.1.0.0 fails

0x9c5a51d7f05acfc6ef075fa6810ffa30

Parallel map and reduce over lists and arrays, a worker pool, select over channels, and timeouts.

bend-kit-concurrency@0.1.0.0 by paymog

Other versions (1)
Published
2026-09-27
Size
12,603 bytes, 1 files
License
MIT-0 (no LICENSE file; the hub's default)
Declarations
0 laws (0 proved), 28 defs, 2 types

Import

import bend-kit-concurrency@0.1.0.0/concurrency.bend as Concurrency
import 0x9c5a51d7f05acfc6ef075fa6810ffa30/concurrency.bend as Concurrency

Modules

Dependencies

No imports from other hub packages.

Dependents

Status on bend 2.0.36

FileStatusChecker saysTime
concurrency.bendfails - expected : @-R:Type -> @k:(@_:Bool -> IO.OP<R>) -> IO.OP<R>
output
Error:
- expected : @-R:Type -> @k:(@_:Bool -> IO.OP<R>) -> IO.OP<R>
- observed : @-R:Type -> @k:(@_:Result<&1, &1, pool.worker~B, Unit> -> IO.OP<R>) -> IO.OP<R>
Context:
- p     : Nat
- q     : Chan(Sigma<&1, &1, pool.worker~A, _ => Chan(pool.worker~B)>)
- s     : pool.worker~S
- b     : pool.worker~B
- reply : Chan(pool.worker~B)
Location: pool.worker
175 |           do IO<S>:
176>|             sent : Bool <- Chan.send(B, reply, b)
    |                            ^^^^^^^^^^^^^^^^^^^^^^
177 |             pool.worker(~S, ~A, ~B, ~work, p, q, WIdle{s})
0.7 s