def stream.reused

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

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

4997def stream.reused(p: Pool, +ms: U32, +head: Bool, +idem: Bool, +key: String, route: Route, spare: Bytes.Bytes,
4998    x: Bool & Result<&1, &1, Err, Stream>) -> IO(Pool & Result<&1, &1, Err, Stream>):
4999  (+none, r) = x
5000  match r:
5001    case Done{st}:
5002      IO.pure(Pool & Result<&1, &1, Err, Stream>, (p, Done{st}))
5003    case Fail{e}:
5004      stream.stale(pool.retry(none, idem), p, ms, head, key, route, spare, e)