reduce_test.go

package gollection_test

import (
	"testing"

	"github.com/azihsoyn/gollection"
	"github.com/stretchr/testify/assert"
)

func TestReduce(t *testing.T) {
	assert := assert.New(t)

	arr := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
	expect := 55

	res, err := gollection.New(arr).Reduce(func(v1, v2 int) int {
		return v1 + v2
	}).Result()
	assert.NoError(err)
	assert.Equal(expect, res)

	var ret int
	err = gollection.New(arr).Reduce(func(v1, v2 int) int {
		return v1 + v2
	}).ResultAs(&ret)
	assert.NoError(err)
	assert.Equal(expect, ret)

	arr = []int{1}
	expect = 1

	res, err = gollection.New(arr).Reduce(func(v1, v2 int) int {
		return v1 + v2
	}).Result()
	assert.NoError(err)
	assert.Equal(expect, res)
}
func TestReduce_NotSlice(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.New("not slice value").Reduce(func(v1, v2 interface{}) interface{} {
		return ""
	}).Result()
	assert.Error(err)
}
func TestReduce_NotFunc(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.New([]int{0, 0, 0}).Reduce(0).Result()
	assert.Error(err)
}

func TestReduce_EmptySlice(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.New([]int{}).Reduce(func(v1, v2 interface{}) interface{} {
		return ""
	}).Result()
	assert.Error(err)
}

func TestReduce_HavingError(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.New("not slice value").
		Reduce(func(v1, v2 interface{}) interface{} {
			return ""
		}).
		Reduce(func(v1, v2 interface{}) interface{} {
			return ""
		}).
		Result()
	assert.Error(err)
}

func TestReduce_Stream(t *testing.T) {
	assert := assert.New(t)

	arr := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
	expect := 55

	res, err := gollection.NewStream(arr).Reduce(func(v1, v2 int) int {
		return v1 + v2
	}).Result()
	assert.NoError(err)
	assert.Equal(expect, res)

	arr = []int{1}
	expect = 1

	res, err = gollection.NewStream(arr).Reduce(func(v1, v2 int) int {
		return v1 + v2
	}).Result()
	assert.NoError(err)
	assert.Equal(expect, res)
}
func TestReduce_Stream_NotSlice(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.NewStream("not slice value").Reduce(func(v1, v2 interface{}) interface{} {
		return ""
	}).Result()
	assert.Error(err)
}
func TestReduce_Stream_NotFunc(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.NewStream([]int{0, 0, 0}).Reduce(0).Result()
	assert.Error(err)
}

func TestReduce_Stream_EmptySlice(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.NewStream([]int{}).Reduce(func(v1, v2 interface{}) interface{} {
		return ""
	}).Result()
	assert.Error(err)
}

func TestReduce_Stream_HavingError(t *testing.T) {
	assert := assert.New(t)
	_, err := gollection.NewStream("not slice value").
		Reduce(func(v1, v2 interface{}) interface{} {
			return ""
		}).
		Reduce(func(v1, v2 interface{}) interface{} {
			return ""
		}).
		Result()
	assert.Error(err)
}