Server.stream_decoded: def of bendonnect-rpc@0.1.0.0
Import: import bendonnect-rpc@0.1.0.0/src/transport/server.bend as Server
Lines 162-167 of bendonnect-rpc@0.1.0.0/src/transport/server.bend: https://jend.leeeet.dev/read.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&start_line=162&end_line=167

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

def 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:
  match r:
    case Fail{reason}:
      early_stream(codec, decode_err(reason))
    case Done{envs}:
      stream_done(procedure, codec, headers, t, msgs(envs))

Uses (13):
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=List
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Map
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Maybe
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=Result
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=String
  https://jend.leeeet.dev/definition.txt?path=Base/base.bend&name=U32
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/envelope.bend&name=Envelope
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/protocol.bend&name=Codec
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&name=Pre
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&name=decode_err
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&name=early_stream
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&name=msgs
  https://jend.leeeet.dev/definition.txt?path=bendonnect-rpc@0.1.0.0/src/transport/server.bend&name=stream_done