def send.go

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

import bendonnect-rpc@0.1.0.0/src/transport/rpc.bend as Rpc
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

102# Sends one typed message on a server stream.
103def send.go(~T: Data, ~enc: @+codec: P.Codec -> T -> Bytes.Bytes, sink2: IO(Srv.Sink), codec: P.Codec) -> IO(Out):
104  do IO<Out>:
105    s : Srv.Sink <- sink2
106    return Out{s, codec}

Uses (7)

Used by (1)