From 985b3cddd8fb27b95e564bcaa3bcdf794a8121ac Mon Sep 17 00:00:00 2001 From: dudaodong Date: Sun, 24 Apr 2022 10:26:07 +0800 Subject: [PATCH] fix: fix TestTee func --- concurrency/channel_test.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/concurrency/channel_test.go b/concurrency/channel_test.go index f2b6834..e6e073f 100644 --- a/concurrency/channel_test.go +++ b/concurrency/channel_test.go @@ -163,12 +163,16 @@ func TestTee(t *testing.T) { defer cancel() c := NewChannel() - inStream := c.Take(ctx, c.Repeat(ctx, 1, 2), 4) + inStream := c.Take(ctx, c.Repeat(ctx, 1), 4) out1, out2 := c.Tee(ctx, inStream) for val := range out1 { - assert.Equal(1, val) - assert.Equal(1, <-out2) + val1 := val + val2 := <-out2 + // t.Log("val1 is", val1) + // t.Log("val2 is", val2) + assert.Equal(1, val1) + assert.Equal(1, val2) } }