Commit9d8681b

committed

test pubsub

1 parent02258ee commit9d8681bCopy full SHA for 9d8681b

File tree

-1

lines changed

-1

lines changed

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -63,5 +63,9 @@ func TestDriver(t *testing.T) {`
`63`	`63`	`err=ps.Publish("test", []byte("hello"))`
`64`	`64`	`require.NoError(t,err)`
`65`	`65`
`66`		`-<-gotChan`
	`66`	`+select {`
	`67`	`+case<-gotChan:`
	`68`	`+case<-ctx.Done():`
	`69`	`+require.Fail(t,"timed out waiting for message")`
	`70`	`+}`
`67`	`71`	`}`

Comments

(0)