go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

Fix parallel test

Browse Source
This commit is contained in:
asim 2024-07-07 18:18:43 +01:00
parent fc614aef2d
commit 12e8fcd057
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
events/stream_test.go
View File

@ -30,18 +30,14 @@ func TestStream(t *testing.T) {
for _, tc := range tcs {
t.Run(tc.name, func(t *testing.T) {
t.Parallel()
runTestStream(t, tc.str)
})
}
}
func runTestStream(t *testing.T, stream Stream) {
t.Parallel()
// TestMissingTopic will test the topic validation on publish
t.Run("TestMissingTopic", func(t *testing.T) {
t.Parallel()
err := stream.Publish("", nil)
assert.Equalf(t, err, ErrMissingTopic, "Publishing to a blank topic should return an error")
})