func()

in servicebus/servicebus_fake.go [56:67]

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

func (r *FakeReceiver) ReceiveMessage(_ context.Context) ([]byte, error) {
	r.client.mu.Lock()
	defer r.client.mu.Unlock()

	if len(r.client.messages) == 0 {
		return nil, errors.New("No messages available.")
	}

	message := r.client.messages[0]
	r.client.messages = r.client.messages[1:]
	return message, nil
}