Function TestTryDial_AppliesDialTimeoutWhenSet

internal/pool/try_dial_test.go:11–28

(t *testing.T)

)

func TestTryDial_AppliesDialTimeoutWhenSet(t *testing.T) {
	p := NewConnPool(&Options{
		Dialer: func(ctx context.Context) (net.Conn, error) {
			if _, ok := ctx.Deadline(); !ok {
				return nil, errors.New("expected deadline in tryDial")
			}
			c1, c2 := net.Pipe()
			_ = c2.Close()
			return c1, nil
		},
		PoolSize:           1,
		MaxConcurrentDials: 1,
		DialTimeout:        200 * time.Millisecond,
	})
	defer p.Close()

	p.tryDial()
}

func TestTryDial_DoesNotApplyDialTimeoutWhenDisabled(t *testing.T) {
	p := NewConnPool(&Options{