Update cogroup_test.go

devfans · Feb 1, 2021 · ad0e95b · ad0e95b
1 parent 9b5634b
commit ad0e95b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cogroup_test.go b/cogroup_test.go
@@ -7,9 +7,9 @@ import (
 )
 
 func Test_CoGroup(t *testing.T) {
-	f := func(context.Context) error {
+	f := func(ctx context.Context) error {
 		<-time.After(time.Second)
-		t.Log("xxxxxxxxxxxxxxxxxx")
+		t.Log(GetWorkerId(ctx),"xxxxxxxxxxxxxxxxxx")
 		return nil
 	}