Server.accept_pump: def of cswap-bend-cli@0.1.0.0 Import: import cswap-bend-cli@0.1.0.0/server.bend as Server Lines 181-188 of cswap-bend-cli@0.1.0.0/server.bend: https://jend.leeeet.dev/read.txt?path=cswap-bend-cli@0.1.0.0/server.bend&start_line=181&end_line=188 import Base import cswap-bend-cli@0.1.0.0/fmt/out.bend as O @unsafe def accept_pump(p: AP, +fmt: O.Fmt) -> IO(Unit): match p: case AAcc{l}: IO.bind(Listener & Result<&1, &1, U32 & String, Socket>, Unit, TCP.accept(l), r => accept_pump(after_accept(r), fmt)) case AConn{l, s}: IO.bind(Unit, Unit, conn_pump(CRecv{s, ""}, fmt), u => accept_pump(AAcc{l}, fmt)) case ARetry{l}: IO.bind(Unit, Unit, IO.sleep(100), u => accept_pump(AAcc{l}, fmt)) Uses (16): 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=Listener https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Pair https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Socket https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=String https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=TCP.accept 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=cswap-bend-cli@0.1.0.0/fmt/out.bend&name=Fmt https://jend.leeeet.dev/definition.txt?path=cswap-bend-cli@0.1.0.0/server.bend&name=AP https://jend.leeeet.dev/definition.txt?path=cswap-bend-cli@0.1.0.0/server.bend&name=CP https://jend.leeeet.dev/definition.txt?path=cswap-bend-cli@0.1.0.0/server.bend&name=after_accept https://jend.leeeet.dev/definition.txt?path=cswap-bend-cli@0.1.0.0/server.bend&name=conn_pump