test: improve coverage for NSQ with channel

appleboy · appleboy · commit bb74ab988693 · 2021-07-25T09:19:43.000+08:00
diff --git a/nsq/nsq_test.go b/nsq/nsq_test.go
@@ -18,6 +18,7 @@ func TestDefaultFlow(t *testing.T) {
 	w := NewWorker(
 		WithAddr(host+":4150"),
 		WithTopic("test"),
+		WithChannel("test"),
 	)
 	q, err := queue.NewQueue(
 		queue.WithWorker(w),

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@ func TestDefaultFlow(t *testing.T) {`
`18`	`18`	`w := NewWorker(`
`19`	`19`	`WithAddr(host+":4150"),`
`20`	`20`	`WithTopic("test"),`
	`21`	`+ WithChannel("test"),`
`21`	`22`	`)`
`22`	`23`	`q, err := queue.NewQueue(`
`23`	`24`	`queue.WithWorker(w),`