Skip to content

Commit

Permalink
test: parallel tests everywhere (#228)
Browse files Browse the repository at this point in the history
  • Loading branch information
@samber
samber committed Oct 2, 2022
1 parent 282789f commit 31f3bc3
Show file tree
Hide file tree
Showing 12 changed files with 122 additions and 26 deletions.
26 changes: 0 additions & 26 deletions channel_test.go
View file
Expand Up @@ -7,32 +7,6 @@ import (
"github.com/stretchr/testify/assert"
)

func TestChannelDispatcher2(t *testing.T) {
ch := make(chan int, 42)
for i := 0; i <= 10; i++ {
ch <- i
}

children := ChannelDispatcher(ch, 5, 10, DispatchingStrategyRoundRobin[int])
// []<-chan int{...}

consumer := func(c <-chan int) {
for {
msg, ok := <-c
if !ok {
println("closed")
break
}

println(msg)
}
}

for i := range children {
go consumer(children[i])
}
}

func TestChannelDispatcher(t *testing.T) {
t.Parallel()
testWithTimeout(t, 100*time.Millisecond)
Expand Down
5 changes: 5 additions & 0 deletions condition_test.go
View file
Expand Up @@ -7,6 +7,7 @@ import (
)

func TestTernary(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Ternary(true, "a", "b")
Expand All @@ -17,6 +18,7 @@ func TestTernary(t *testing.T) {
}

func TestIfElse(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := If(true, 1).ElseIf(false, 2).Else(3)
Expand All @@ -31,6 +33,7 @@ func TestIfElse(t *testing.T) {
}

func TestIfFElseF(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := IfF(true, func() int { return 1 }).ElseIfF(false, func() int { return 2 }).ElseF(func() int { return 3 })
Expand All @@ -45,6 +48,7 @@ func TestIfFElseF(t *testing.T) {
}

func TestSwitchCase(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Switch[int, int](42).Case(42, 1).Case(1, 2).Default(3)
Expand All @@ -59,6 +63,7 @@ func TestSwitchCase(t *testing.T) {
}

func TestSwitchCaseF(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Switch[int, int](42).CaseF(42, func() int { return 1 }).CaseF(1, func() int { return 2 }).DefaultF(func() int { return 3 })
Expand Down
20 changes: 20 additions & 0 deletions find_test.go
View file
Expand Up @@ -11,6 +11,7 @@ import (
)

func TestIndexOf(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := IndexOf([]int{0, 1, 2, 1, 2, 3}, 2)
Expand All @@ -21,6 +22,7 @@ func TestIndexOf(t *testing.T) {
}

func TestLastIndexOf(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := LastIndexOf([]int{0, 1, 2, 1, 2, 3}, 2)
Expand All @@ -31,6 +33,7 @@ func TestLastIndexOf(t *testing.T) {
}

func TestFind(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1, ok1 := Find([]string{"a", "b", "c", "d"}, func(i string) bool {
Expand All @@ -47,6 +50,7 @@ func TestFind(t *testing.T) {
}

func TestFindIndexOf(t *testing.T) {
t.Parallel()
is := assert.New(t)

item1, index1, ok1 := FindIndexOf([]string{"a", "b", "c", "d", "b"}, func(i string) bool {
Expand All @@ -65,6 +69,7 @@ func TestFindIndexOf(t *testing.T) {
}

func TestFindLastIndexOf(t *testing.T) {
t.Parallel()
is := assert.New(t)

item1, index1, ok1 := FindLastIndexOf([]string{"a", "b", "c", "d", "b"}, func(i string) bool {
Expand All @@ -83,6 +88,7 @@ func TestFindLastIndexOf(t *testing.T) {
}

func TestFindOrElse(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := FindOrElse([]string{"a", "b", "c", "d"}, "x", func(i string) bool {
Expand All @@ -97,6 +103,7 @@ func TestFindOrElse(t *testing.T) {
}

func TestFindKey(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1, ok1 := FindKey(map[string]int{"foo": 1, "bar": 2, "baz": 3}, 2)
Expand All @@ -121,6 +128,7 @@ func TestFindKey(t *testing.T) {
}

func TestFindKeyBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1, ok1 := FindKeyBy(map[string]int{"foo": 1, "bar": 2, "baz": 3}, func(k string, v int) bool {
Expand All @@ -137,6 +145,7 @@ func TestFindKeyBy(t *testing.T) {
}

func TestFindUniques(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := FindUniques[int]([]int{1, 2, 3})
Expand All @@ -161,6 +170,7 @@ func TestFindUniques(t *testing.T) {
}

func TestFindUniquesBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := FindUniquesBy[int, int]([]int{0, 1, 2}, func(i int) int {
Expand Down Expand Up @@ -193,6 +203,7 @@ func TestFindUniquesBy(t *testing.T) {
}

func TestFindDuplicates(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := FindDuplicates[int]([]int{1, 2, 2, 1, 2, 3})
Expand All @@ -212,6 +223,7 @@ func TestFindDuplicates(t *testing.T) {
}

func TestFindDuplicatesBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := FindDuplicatesBy[int, int]([]int{3, 4, 5, 6, 7}, func(i int) int {
Expand All @@ -237,6 +249,7 @@ func TestFindDuplicatesBy(t *testing.T) {
}

func TestMin(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Min([]int{1, 2, 3})
Expand All @@ -249,6 +262,7 @@ func TestMin(t *testing.T) {
}

func TestMinBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := MinBy([]string{"s1", "string2", "s3"}, func(item string, min string) bool {
Expand All @@ -267,6 +281,7 @@ func TestMinBy(t *testing.T) {
}

func TestMax(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Max([]int{1, 2, 3})
Expand All @@ -279,6 +294,7 @@ func TestMax(t *testing.T) {
}

func TestMaxBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := MaxBy([]string{"s1", "string2", "s3"}, func(item string, max string) bool {
Expand All @@ -297,6 +313,7 @@ func TestMaxBy(t *testing.T) {
}

func TestLast(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1, err1 := Last([]int{1, 2, 3})
Expand All @@ -309,6 +326,7 @@ func TestLast(t *testing.T) {
}

func TestNth(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1, err1 := Nth([]int{0, 1, 2, 3}, 2)
Expand All @@ -333,6 +351,7 @@ func TestNth(t *testing.T) {
}

func TestSample(t *testing.T) {
t.Parallel()
is := assert.New(t)

rand.Seed(time.Now().UnixNano())
Expand All @@ -345,6 +364,7 @@ func TestSample(t *testing.T) {
}

func TestSamples(t *testing.T) {
t.Parallel()
is := assert.New(t)

rand.Seed(time.Now().UnixNano())
Expand Down
1 change: 1 addition & 0 deletions func_test.go
View file
Expand Up @@ -8,6 +8,7 @@ import (
)

func TestPartial(t *testing.T) {
t.Parallel()
is := assert.New(t)

add := func(x float64, y int) string {
Expand Down
16 changes: 16 additions & 0 deletions intersect_test.go
View file
Expand Up @@ -7,6 +7,7 @@ import (
)

func TestContains(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Contains([]int{0, 1, 2, 3, 4, 5}, 5)
Expand All @@ -17,6 +18,7 @@ func TestContains(t *testing.T) {
}

func TestContainsBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

type a struct {
Expand All @@ -39,6 +41,7 @@ func TestContainsBy(t *testing.T) {
}

func TestEvery(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Every([]int{0, 1, 2, 3, 4, 5}, []int{0, 2})
Expand All @@ -53,6 +56,7 @@ func TestEvery(t *testing.T) {
}

func TestEveryBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := EveryBy([]int{1, 2, 3, 4}, func(x int) bool {
Expand Down Expand Up @@ -81,6 +85,7 @@ func TestEveryBy(t *testing.T) {
}

func TestSome(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Some([]int{0, 1, 2, 3, 4, 5}, []int{0, 2})
Expand All @@ -95,6 +100,7 @@ func TestSome(t *testing.T) {
}

func TestSomeBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := SomeBy([]int{1, 2, 3, 4}, func(x int) bool {
Expand Down Expand Up @@ -123,6 +129,7 @@ func TestSomeBy(t *testing.T) {
}

func TestNone(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := None([]int{0, 1, 2, 3, 4, 5}, []int{0, 2})
Expand All @@ -137,6 +144,7 @@ func TestNone(t *testing.T) {
}

func TestNoneBy(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := NoneBy([]int{1, 2, 3, 4}, func(x int) bool {
Expand Down Expand Up @@ -165,6 +173,7 @@ func TestNoneBy(t *testing.T) {
}

func TestIntersect(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Intersect([]int{0, 1, 2, 3, 4, 5}, []int{0, 2})
Expand All @@ -181,6 +190,7 @@ func TestIntersect(t *testing.T) {
}

func TestDifference(t *testing.T) {
t.Parallel()
is := assert.New(t)

left1, right1 := Difference([]int{0, 1, 2, 3, 4, 5}, []int{0, 2, 6})
Expand All @@ -197,7 +207,9 @@ func TestDifference(t *testing.T) {
}

func TestUnion(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Union([]int{0, 1, 2, 3, 4, 5}, []int{0, 2, 10})
result2 := Union([]int{0, 1, 2, 3, 4, 5}, []int{6, 7})
result3 := Union([]int{0, 1, 2, 3, 4, 5}, []int{})
Expand All @@ -211,7 +223,9 @@ func TestUnion(t *testing.T) {
}

func TestWithout(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := Without([]int{0, 2, 10}, 0, 1, 2, 3, 4, 5)
result2 := Without([]int{0, 7}, 0, 1, 2, 3, 4, 5)
result3 := Without([]int{}, 0, 1, 2, 3, 4, 5)
Expand All @@ -225,7 +239,9 @@ func TestWithout(t *testing.T) {
}

func TestWithoutEmpty(t *testing.T) {
t.Parallel()
is := assert.New(t)

result1 := WithoutEmpty([]int{0, 1, 2})
result2 := WithoutEmpty([]int{1, 2})
result3 := WithoutEmpty([]int{})
Expand Down

0 comments on commit 31f3bc3

Please sign in to comment.