def Stream.fed

bend-kube-runtime@0.2.0.0 · src/stream.bend:59

import Base
import bend-kube-runtime@0.2.0.0/src/http.bend as H

59# Feeds a cut (empty at the end of the stream) and takes the body bytes it
60# decoded.
61def Stream.fed(s: Socket, +bs: List<&2, U32>, r: H.Resp) -> SEv:
62  Stream.taken(s, List.is_empty(&2, U32, bs),
63    H.Http.take(Stream.ended(List.is_empty(&2, U32, bs), H.Http.feed(bs, r))))