Function
newSerdes
(
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 | |
| 129 | func 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 | } |
Tested by
no test coverage detected