def open

bend-kit-http@0.38.2.0 · completion.bend:27

import Base

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