Function TestMapSingleParameter

flow/dataset_map_test.go:8–21

(t *testing.T)

)

func TestMapSingleParameter(t *testing.T) {
	dataset := New().Slice(
		[]int{1, 2, 3},
	).Map(func(t int) (int, int) {
		return t, t
	}).Map(func(x, y int) int {
		return x + y
	})
	got := collectOutput(dataset)

	if want := []int{2, 4, 6}; !reflect.DeepEqual(got, want) {
		t.Errorf("Got: %v want: %v", got, want)
	}
}

func TestGroupByKeyMap(t *testing.T) {
	dataset := New().Slice(