def stream_decoded

bendonnect-rpc@0.1.0.0 · src/transport/server.bend:162

import Base
import bendonnect-rpc@0.1.0.0/src/envelope.bend as Env
import bendonnect-rpc@0.1.0.0/src/protocol.bend as P

162def stream_decoded(procedure: String, codec: P.Codec, headers: Map<&2, List<&2, String>>, t: Maybe<&2, U32>, r: Result<&2, &1, String, List<&1, Env.Envelope>>) -> Pre:
163  match r:
164    case Fail{reason}:
165      early_stream(codec, decode_err(reason))
166    case Done{envs}:
167      stream_done(procedure, codec, headers, t, msgs(envs))