func()

in domain/products_stream.go [20:27]

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

func (p *ProductsStream) Publish(ctx context.Context, events []types.Event) ([]types.FailedEvent, error) {
	failedEvents, err := p.bus.Put(ctx, events)
	if err != nil {
		return failedEvents, fmt.Errorf("%w", err)
	}

	return failedEvents, nil
}