"github.com/anacrolix/missinggo/pubsub"
"github.com/bradfitz/iter"
+ "github.com/frankban/quicktest"
"github.com/stretchr/testify/require"
"github.com/anacrolix/torrent/metainfo"
}
func BenchmarkConnectionMainReadLoop(b *testing.B) {
+ c := quicktest.New(b)
cl := &Client{
config: &ClientConfig{
DownloadRateLimiter: unlimited,
ts.writeSem.Lock()
}
}()
- require.NoError(b, <-mrlErr)
- require.EqualValues(b, b.N, cn._stats.ChunksReadUseful.Int64())
+ c.Assert([]error{nil, io.EOF}, quicktest.Contains, <-mrlErr)
+ c.Assert(cn._stats.ChunksReadUseful.Int64(), quicktest.Equals, int64(b.N))
}
func TestConnPexPeerFlags(t *testing.T) {