func()

in app/pubsub-integration/pubsub/pubsub.go [112:126]

• 14 lines of code
• 3 McCabe index (conditional complexity)

func (c *pubsubClient) NewSubscription(ID string, codec *goavro.Codec, numGoroutines int, maxOutstanding int) *Subscription {
	sub := c.client.Subscription(ID)

	if numGoroutines > 0 {
		sub.ReceiveSettings.NumGoroutines = numGoroutines // default is 10
	}
	if maxOutstanding > 0 {
		sub.ReceiveSettings.MaxOutstandingMessages = maxOutstanding
	}
	return &Subscription{
		ID:           ID,
		subscription: sub,
		codec:        codec,
	}
}