MCPcopy Create free account
hub / github.com/coder/coder / newSerdes

Function newSerdes

vpn/serdes.go:129–140  ·  view source on GitHub ↗
(
	ctx context.Context, logger slog.Logger, conn io.ReadWriteCloser,
	sendCh <-chan S, recvCh chan<- R,
)

Source from the content-addressed store, hash-verified

127}
128
129func newSerdes[S rpcMessage, R receivableRPCMessage[RR], RR any](
130 ctx context.Context, logger slog.Logger, conn io.ReadWriteCloser,
131 sendCh <-chan S, recvCh chan<- R,
132) *serdes[S, R, RR] {
133 return &serdes[S, R, RR]{
134 ctx: ctx,
135 logger: logger.Named("serdes"),
136 conn: conn,
137 sendCh: sendCh,
138 recvCh: recvCh,
139 }
140}

Callers 1

newSpeakerFunction · 0.85

Calls 1

NamedMethod · 0.80

Tested by

no test coverage detected