Concurrency.timeout: def of bend-kit-concurrency@0.2.0.0
Import: import bend-kit-concurrency@0.2.0.0/concurrency.bend as Concurrency
Lines 334-344 of bend-kit-concurrency@0.2.0.0/concurrency.bend: https://jend.leeeet.dev/read.txt?path=bend-kit-concurrency@0.2.0.0/concurrency.bend&start_line=334&end_line=344

import Base

# Some{result} if act finishes within ms milliseconds, else None at the
# deadline. act is not cancelled: it runs on, its late result is dropped, and
# the program waits for it (and for the timer) before it exits.
def timeout(-A: Type, ms: U32, act: IO(A)) -> IO(Maybe<&1, A>):
  do IO<Maybe<&1, A>>:
    chan : Chan(Maybe<&1, A>) <- Chan.new(Maybe<&1, A>, 0)
    +c : Chan(Maybe<&1, A>) = chan
    IO.spawn(Result<&1, &1, Maybe<&1, A>, Unit>, IO.bind(A, Result<&1, &1, Maybe<&1, A>, Unit>, act, x => Chan.send(Maybe<&1, A>, c, Some{x})))
    IO.spawn(Result<&1, &1, Maybe<&1, A>, Unit>, IO.bind(Unit, Result<&1, &1, Maybe<&1, A>, Unit>, IO.sleep(ms), u => Chan.send(Maybe<&1, A>, c, None{})))
    got : Maybe<&1, Maybe<&1, A>> <- Chan.recv(Maybe<&1, A>, c)
    timeout.won(A, c, got)

Uses (13):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.new
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.recv
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.send
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.bind
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.sleep
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=IO.spawn
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Maybe
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=U32
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Unit
  https://jend.leeeet.dev/definition.txt?path=bend-kit-concurrency@0.2.0.0/concurrency.bend&name=timeout.won