def recv.last

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

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
import bendonnect-rpc@0.1.0.0/src/error.bend as E

177def recv.last(st: Http.Stream, last: Bool, data: Bytes.Bytes, rest: Bytes.Bytes) -> IO(Item):
178  match last:
179    case True{}:
180      do IO<Item>:
181        Http.stream.close(st)
182        return over.of(E.end_decode(data))
183    case False{}:
184      IO.pure(Item, Msg{st, data, rest})