def recv.cls

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

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/code.bend as Code

186def recv.cls(st: Http.Stream, compressed: Bool, last: Bool, data: Bytes.Bytes, rest: Bytes.Bytes) -> IO(Item):
187  match compressed:
188    case True{}:
189      do IO<Item>:
190        Http.stream.close(st)
191        return broke(Code.Internal{}, "compressed message but no encoding was negotiated")
192    case False{}:
193      recv.last(st, last, data, rest)