Server.server.stream.go: def of emerging-ezhttp@0.21.0.0
Import: import emerging-ezhttp@0.21.0.0/src/server.bend as Server
Lines 256-265 of emerging-ezhttp@0.21.0.0/src/server.bend: https://jend.leeeet.dev/read.txt?path=emerging-ezhttp@0.21.0.0/src/server.bend&start_line=256&end_line=265

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes
import emerging-ezhttp@0.21.0.0/src/http.bend as Http
import emerging-ezhttp@0.21.0.0/src/step.bend as Step

# every chunk the channel gives, until it is closed
def server.stream.go(fuel: Nat, sock: Socket, +ch: Chan(Bytes.Bytes))
  -> IO(Unit):
  match fuel:
    case 0n:
      IO.bind(Socket & Step.Got<Unit>, Unit,
        server.send.text(sock, Http.chunk.end()), server.close)
    case 1n+f:
      IO.bind(Maybe<&1, Bytes.Bytes>, Unit, Chan.recv(Bytes.Bytes, ch),
        m => server.chunk.got(sock, m, s => server.stream.go(f, s, ch)))

Uses (15):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Chan.recv
  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=Maybe
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Nat
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Pair
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Socket
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Unit
  https://jend.leeeet.dev/definition.txt?path=bend-kit-bytes@0.3.3.0/bytes.bend&name=Bytes
  https://jend.leeeet.dev/definition.txt?path=emerging-ezhttp@0.21.0.0/src/http.bend&name=chunk.end
  https://jend.leeeet.dev/definition.txt?path=emerging-ezhttp@0.21.0.0/src/server.bend&name=server.chunk.got
  https://jend.leeeet.dev/definition.txt?path=emerging-ezhttp@0.21.0.0/src/server.bend&name=server.close
  https://jend.leeeet.dev/definition.txt?path=emerging-ezhttp@0.21.0.0/src/server.bend&name=server.send.text
  https://jend.leeeet.dev/definition.txt?path=emerging-ezhttp@0.21.0.0/src/step.bend&name=Got