fix: fixes ReceiveWithTimeout duplication bug

cludden · cludden · commit 80350106d801 · 2024-01-26T20:38:55.000-07:00
diff --git a/internal/plugin/worker.go b/internal/plugin/worker.go
@@ -404,7 +404,7 @@ func (svc *Service) genWorkerSignalReceiveWithTimeout(f *g.File, signal string)
 				b.Id("resp").Op("=").Op("&").Id(svc.getMessageName(method.Input)).Values()
 			}
 			b.If(
-				b.List(g.Id("ok"), g.Id("more")).Op("=").Id("s").Dot("Channel").Dot("ReceiveWithTimeout").CallFunc(func(args *g.Group) {
+				g.List(g.Id("ok"), g.Id("more")).Op("=").Id("s").Dot("Channel").Dot("ReceiveWithTimeout").CallFunc(func(args *g.Group) {
 					args.Id("ctx")
 					args.Id("timeout")
 					if hasInput {

Original file line number	Diff line number	Diff line change
`@@ -404,7 +404,7 @@ func (svc Service) genWorkerSignalReceiveWithTimeout(f g.File, signal string)`
`404`	`404`	`b.Id("resp").Op("=").Op("&").Id(svc.getMessageName(method.Input)).Values()`
`405`	`405`	`}`
`406`	`406`	`b.If(`
`407`		`- b.List(g.Id("ok"), g.Id("more")).Op("=").Id("s").Dot("Channel").Dot("ReceiveWithTimeout").CallFunc(func(args *g.Group) {`
	`407`	`+ g.List(g.Id("ok"), g.Id("more")).Op("=").Id("s").Dot("Channel").Dot("ReceiveWithTimeout").CallFunc(func(args *g.Group) {`
`408`	`408`	`args.Id("ctx")`
`409`	`409`	`args.Id("timeout")`
`410`	`410`	`if hasInput {`