package main
import (
- "bufio"
"flag"
"log"
"os"
log.Fatalln(err)
}
entsReader := make(chan Ent, 1<<10)
- go reader(bufio.NewReaderSize(db, 1<<17), entsReader)
+ go reader(db, entsReader)
entsPrinter := make(chan Ent, 1<<10)
printerJob := make(chan struct{})