def stream.feed.step

bend-kit-http@0.38.5.0 · http.bend:4738

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

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