func()

in pkg/asyncapi/v2/v2.go [177:188]

• 11 lines of code
• 4 McCabe index (conditional complexity)

func (d Document) filterMessages(filter func(operation asyncapi.Operation) bool) []asyncapi.Message {
	var messages []asyncapi.Message
	for _, c := range d.Channels() {
		for _, o := range c.Operations() {
			if filter(o) {
				messages = append(messages, o.Messages()...)
			}
		}
	}

	return messages
}