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

Method start

vpn/serdes.go:117–127  ·  view source on GitHub ↗

start starts the goroutines that serialize and deserialize to the conn. nolint: revive

()

Source from the content-addressed store, hash-verified

115// start starts the goroutines that serialize and deserialize to the conn.
116// nolint: revive
117func (s *serdes[_, _, _]) start() {
118 s.wg.Add(2)
119 go func() {
120 defer s.wg.Done()
121 s.recvLoop()
122 }()
123 go func() {
124 defer s.wg.Done()
125 s.sendLoop()
126 }()
127}
128
129func newSerdes[S rpcMessage, R receivableRPCMessage[RR], RR any](
130 ctx context.Context, logger slog.Logger, conn io.ReadWriteCloser,

Callers

nothing calls this directly

Calls 4

sendLoopMethod · 0.95
AddMethod · 0.65
DoneMethod · 0.45
recvLoopMethod · 0.45

Tested by

no test coverage detected