commit 68b84d7de9f80a201534bab0e1a68fac8c2e77a7
parent 53aa594e2a908ee689d67fd40ff3da0bc273442f
Author: francoispqt <francois@parquet.ninja>
Date: Sat, 19 May 2018 23:45:31 +0800
update encoding stream test
Diffstat:
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/encode_stream_test.go b/encode_stream_test.go
@@ -301,8 +301,8 @@ func TestEncodeStream(t *testing.T) {
enc := Stream.NewEncoder(w).NConsumer(50).LineDelimited()
w.enc = enc
s := StreamChanObject(make(chan *testObject))
- go enc.EncodeStream(s)
go feedStream(s, 5000)
+ go enc.EncodeStream(s)
select {
case <-enc.Done():
assert.Nil(t, enc.Err(), "enc.Err() should be nil")