def send

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

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/envelope.bend as Env

42# One enveloped message, written (and flushed) immediately.
43def send(sink: Sink, msg: Bytes.Bytes) -> IO(Sink):
44  Sink{w} = sink
45  do IO<Sink>:
46    w2 : Http.Writer <- Http.writer.write(w, Env.encode(Env.Envelope{0, msg}))
47    return Sink{w2}