(t *testing.T)
| 257 | } |
| 258 | |
| 259 | func TestClientClose(t *testing.T) { |
| 260 | client, server := net.Pipe() |
| 261 | defer server.Close() |
| 262 | |
| 263 | c := &Client{ |
| 264 | config: Config{Caster: "localhost:2101", Mountpoint: "/M", Password: "p"}, |
| 265 | conn: client, |
| 266 | logger: slog.Default(), |
| 267 | } |
| 268 | |
| 269 | require.NoError(t, c.Close()) |
| 270 | require.Nil(t, c.conn) |
| 271 | |
| 272 | _, err := c.Write([]byte("data")) |
| 273 | require.Error(t, err) |
| 274 | } |
| 275 | |
| 276 | func TestClientConnectDialFailure(t *testing.T) { |
| 277 | c := NewClient(Config{ |