def drain

bendonnect-rpc@0.1.0.0 · src/transport/client.bend:125

import Base
import bend-kit-http@0.36.0.0/http.bend as Http
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

125def drain(st: Http.Stream, acc: Bytes.Bytes) -> IO(Bytes.Bytes):
126  do IO<Bytes.Bytes>:
127    m : Http.Stream & Result<&1, &1, Http.Err, Maybe<&1, Bytes.Bytes>> <- Http.stream.read(st)
128    drain.step(m, acc)
129
130@unsafe