def stream_single.go

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

import Base
import bend-kit-http@0.36.0.0/http.bend as Http
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes
import bendonnect-rpc@0.1.0.0/src/error.bend as E
import bendonnect-rpc@0.1.0.0/src/envelope.bend as Env

278def stream_single.go(r: Result<&1, &1, E.Error, Bytes.Bytes>, ct: String, hs: Map<&2, List<&2, String>>, ts: Map<&2, List<&2, String>>) -> IO(Http.WriteHead<Job>):
279  match r:
280    case Done{b}:
281      head(200, ct_hdr(hs, ct), Bytes.concat(Env.encode(Env.Envelope{0, b}) <> end_env(None{}, ts) <> Nil{}))
282    case Fail{e}:
283      head(200, ct_hdr(hs, ct), end_env(Some{e}, ts))