"log"
"math/rand"
"sync"
+ "testing"
"time"
- "github.com/bradfitz/iter"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"golang.org/x/time/rate"
-
- "testing"
)
func writeN(ws []io.Writer, n int) error {
}
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)