def rv.step

bend-kit-http@0.38.2.0 · http.bend:1445

import Base
import bend-kit-bytes@0.3.3.0/bytes.bend as Bytes

1445# One read: piece, or the server closed (RFC 9112 §8: a message cut short is not a message).
1446def rv.step(closed: Bool, +head: Bool, rv: Rv, piece: Bytes.Bytes) -> Rt:
1447  match closed:
1448    case True{}:
1449      match rv:
1450        case RvHead{buf, k}:
1451          RtBad{}
1452        case RvBody{res, rb, parts}:
1453          rv.eof(res, parts, rb.eof(rb))
1454        case RvLen{res, left, body}:
1455          RtBad{}
1456    case False{}:
1457      match rv:
1458        case RvHead{buf, +k}:
1459          rv.head(hs.more(head, k, buf, piece))
1460        case RvBody{res, rb, parts}:
1461          rv.fed(res, rb.feed(rb, parts, piece))
1462        case RvLen{res, +left, body}:
1463          rl.feed(res, left, body, piece)