Client.pump: def of bendonnect-rpc@0.1.0.0
Import: import bendonnect-rpc@0.1.0.0/src/transport/client.bend as Client
Lines 238-248 of bendonnect-rpc@0.1.0.0/src/transport/client.bend: https://jend.leeeet.dev/read.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&start_line=238&end_line=248

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes
import bendonnect-rpc@0.1.0.0/src/error.bend as E

def pump(~on_msg: Bytes.Bytes -> IO(Unit), +collect: Bool, item: Item, acc: List<&1, Bytes.Bytes>) -> IO(Result<&1, &1, E.Error, Fin>):
  match item:
    case Msg{st, data, rest}:
      do IO<Result<&1, &1, E.Error, Fin>>:
        acc2 : List<&1, Bytes.Bytes> <- emit(~on_msg, collect, data, acc)
        next : Item <- recv(st, rest)
        pump(~on_msg, collect, next, acc2)
    case Over{error, metadata}:
      IO.pure(Result<&1, &1, E.Error, Fin>, end.done(error, metadata, acc))
    case Broke{e}:
      IO.pure(Result<&1, &1, E.Error, Fin>, Fail{e})

Uses (14):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Bool
  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=List
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result
  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=bendonnect-rpc@0.1.0.0/src/error.bend&name=Error
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&name=Fin
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&name=Item
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&name=emit
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&name=end.done
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/client.bend&name=recv