func New()

in e2etestrunner/testclient/testclient.go [53:66]

• 13 lines of code
• 2 McCabe index (conditional complexity)

func New(ctx context.Context, projectID string, pubsubInfo *setuptf.PubsubInfo) (*Client, error) {
	pubsub, err := pubsub.NewClient(ctx, projectID)
	if err != nil {
		return nil, err
	}
	client := &Client{
		pubsubClient:         pubsub,
		requestTopic:         pubsub.Topic(pubsubInfo.RequestTopic.TopicName),
		responseSubscription: pubsub.Subscription(pubsubInfo.ResponseTopic.SubscriptionName),
	}
	// Disable buffering
	client.requestTopic.PublishSettings.CountThreshold = 1
	return client, nil
}