start starts the goroutines that serialize and deserialize to the conn. nolint: revive
()
| 115 | // start starts the goroutines that serialize and deserialize to the conn. |
| 116 | // nolint: revive |
| 117 | func (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 | |
| 129 | func newSerdes[S rpcMessage, R receivableRPCMessage[RR], RR any]( |
| 130 | ctx context.Context, logger slog.Logger, conn io.ReadWriteCloser, |