def stream.feed.step

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

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

4734def stream.feed.step(st: Fed, d: Zlib.Decoder) -> IO(Fed):
4735  Fed{done, body} = st
4736  match body:
4737    case Fail{e}:
4738      IO.pure(Fed, Fed{d <> done, Fail{e}})
4739    case Done{b}:
4740      do IO<Fed>:
4741        m : Zlib.Decoder & Result<&1, &1, U32 & String, Bytes.Bytes> <- Zlib.dec.push(d, 16777216, b)
4742        return stream.feed.received(done, m)