def stream.reused

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

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

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