git/lancet
1
0
Fork 0
mirror of https://github.com/duke-git/lancet.git synced 2026-02-12 08:42:29 +08:00
Code Issues Projects Releases Wiki Activity

fix: fix TestTee func

Browse Source
This commit is contained in:
dudaodong
2022-04-24 10:26:07 +08:00
parent abadeec007
commit 985b3cddd8
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
concurrency/channel_test.go
View File

@@ -163,12 +163,16 @@ func TestTee(t *testing.T) {
defer cancel() defer cancel()
c := NewChannel() 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) out1, out2 := c.Tee(ctx, inStream)
for val := range out1 { for val := range out1 {
assert.Equal(1, val) val1 := val
assert.Equal(1, <-out2) val2 := <-out2
// t.Log("val1 is", val1)
// t.Log("val2 is", val2)
assert.Equal(1, val1)
assert.Equal(1, val2)
} }
} }