From ad0e95bd9b5354afeffbef71b7d196d5a92a2743 Mon Sep 17 00:00:00 2001 From: Stefan Liu Date: Mon, 1 Feb 2021 10:23:22 +0800 Subject: [PATCH] Update cogroup_test.go --- cogroup_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cogroup_test.go b/cogroup_test.go index fdf370d..dcf36bb 100644 --- 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 }