nolint:revive // t takes precedence.
(t *testing.T, ctx context.Context, conn net.Conn)
| 1250 | |
| 1251 | // nolint:revive // t takes precedence. |
| 1252 | func writeReadEcho(t *testing.T, ctx context.Context, conn net.Conn) { |
| 1253 | msg := namesgenerator.UniqueName() |
| 1254 | |
| 1255 | deadline, ok := ctx.Deadline() |
| 1256 | if ok { |
| 1257 | _ = conn.SetWriteDeadline(deadline) |
| 1258 | defer conn.SetWriteDeadline(time.Time{}) |
| 1259 | _ = conn.SetReadDeadline(deadline) |
| 1260 | defer conn.SetReadDeadline(time.Time{}) |
| 1261 | } |
| 1262 | |
| 1263 | // Write a message |
| 1264 | _, err := conn.Write([]byte(msg)) |
| 1265 | require.NoError(t, err) |
| 1266 | |
| 1267 | // Read the message back |
| 1268 | buf := make([]byte, 1024) |
| 1269 | n, err := conn.Read(buf) |
| 1270 | require.NoError(t, err) |
| 1271 | require.Equal(t, msg, string(buf[:n])) |
| 1272 | } |
no test coverage detected