Function TestBatch

batch_test.go:10–28

(t *testing.T)

)

func TestBatch(t *testing.T) {
	// most logic is covered by the chans pkg tests

	t.Run("correctness", func(t *testing.T) {
		in := FromChan(th.FromRange(0, 10), fmt.Errorf("err0"))
		in = replaceWithError(in, 5, fmt.Errorf("err5"))
		in = replaceWithError(in, 7, fmt.Errorf("err7"))

		batches, errs := toSliceAndErrors(Batch(in, 3, -1))

		th.ExpectValue(t, len(batches), 3)
		th.ExpectSlice(t, batches[0], []int{0, 1, 2})
		th.ExpectSlice(t, batches[1], []int{3, 4, 6})
		th.ExpectSlice(t, batches[2], []int{8, 9})

		th.ExpectSlice(t, errs, []string{"err0", "err5", "err7"})
	})

}

func TestUnbatch(t *testing.T) {
	// most logic is covered by the common package tests