def stream.take

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

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

5021# Copy the request only for a reused socket, for a stale-socket retry.
5022def stream.take(taken: Pool & Maybe<&1, Conn>, +ms: U32, +head: Bool, +idem: Bool, +key: String, route: Route,
5023    wire: Bytes.Bytes) -> IO(Pool & Result<&1, &1, Err, Stream>):
5024  (p, m) = taken
5025  match m:
5026    case None{}:
5027      do IO<Pool & Result<&1, &1, Err, Stream>>:
5028        got : Result<&1, &1, Err, Stream> <- stream.fresh(ms, head, Some{key}, route, wire)
5029        return (p, got)
5030    case Some{c}:
5031      stream.idle(p, ms, head, idem, key, route, Bytes.slice(wire, 0, 4294967295), c)