"testing"
"time"
- "github.com/bradfitz/iter"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"golang.org/x/time/rate"
}
reads := make(chan read)
done := make(chan struct{})
- for range iter.N(numReaders) {
+ for i := 0; i < numReaders; i += 1 {
r, w := io.Pipe()
ws = append(ws, w)
cs = append(cs, w)
}()
written := 0
go func() {
- for range iter.N(writeRounds) {
+ for i := 0; i < writeRounds; i += 1 {
err := writeN(ws, bytesPerRound)
if err != nil {
log.Printf("error writing: %s", err)