Skip to content

Commit

Permalink
Fix parallel test
Browse files Browse the repository at this point in the history
  • Loading branch information
asim committed Jul 7, 2024
1 parent fc614ae commit 12e8fcd
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions events/stream_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
})
Expand Down

0 comments on commit 12e8fcd

Please sign in to comment.