Method dial

internal/nodehub/hub_test.go:69–81

(t *testing.T)

}

func (e *testEnv) dial(t *testing.T) *grpc.ClientConn {
	t.Helper()
	cc, err := grpc.NewClient(
		"passthrough:///bufnet",
		grpc.WithContextDialer(e.dialFn),
		grpc.WithTransportCredentials(insecure.NewCredentials()),
	)
	if err != nil {
		t.Fatalf("dial: %v", err)
	}
	t.Cleanup(func() { _ = cc.Close() })
	return cc
}

// nodeMock 模拟一个 node 客户端，启动一个 Session 流，可注册 method handler。
type nodeMock struct {