def send

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

import Base
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes
import bendonnect-rpc@0.1.0.0/src/protocol.bend as P
import bendonnect-rpc@0.1.0.0/src/transport/server.bend as Srv

108def send(~T: Data, ~enc: @+codec: P.Codec -> T -> Bytes.Bytes, out: Out, msg: T) -> IO(Out):
109  Out{sink, +codec} = out
110  send.go(~T, ~enc, Srv.send(sink, enc(codec, msg)), codec)