Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Parallel tests everywhere #228

Merged
merged 1 commit into from Oct 2, 2022
Merged

Parallel tests everywhere #228

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
26 changes: 0 additions & 26 deletions channel_test.go
View file
Open in desktop
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
Open in desktop
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
Open in desktop
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
Open in desktop
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
Open in desktop
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