func NewPublishers()

in app/eventgen/generator/publishers/publishers.go [42:51]

• 10 lines of code
• 1 McCabe index (conditional complexity)

func NewPublishers(topic pubsub.Topic, newMessage NewMessage, timeout time.Duration) *Publishers {
	var mux sync.Mutex
	return &Publishers{
		Topic:      topic,
		newMessage: newMessage,
		timeout:    timeout,
		Locker:     &mux,
		waitFinish: sync.NewCond(&mux),
	}
}