Completion.open: def of bend-kit-http@0.38.2.0
Import: import bend-kit-http@0.38.2.0/completion.bend as Completion
Lines 27-32 of bend-kit-http@0.38.2.0/completion.bend: https://jend.leeeet.dev/read.txt?path=bend-kit-http@0.38.2.0/completion.bend&start_line=27&end_line=32

import Base

# The observer owns IO.join/explicit close, including when it receives later.
# Closing before reception is disposal; it never carries affine resources.
def open(~D: Data, payload: D) -> IO(Receipt & Chan(Completion<D>)):
  do IO<Receipt & Chan(Completion<D>)>:
    +channel : Chan(Completion<D>) <- Chan.new(Completion<D>, 1)
    return (Observed{status => outcome => receipt.send(~D, payload, channel, status, outcome)}, channel)

Uses (10):
  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=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.pure
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Pair
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Sigma
  https://jend.leeeet.dev/definition.txt?path=bend-kit-http@0.38.2.0/completion.bend&name=Completion
  https://jend.leeeet.dev/definition.txt?path=bend-kit-http@0.38.2.0/completion.bend&name=Receipt
  https://jend.leeeet.dev/definition.txt?path=bend-kit-http@0.38.2.0/completion.bend&name=receipt.send