Remove buffering from results channel

veggiedefender · Jan 4, 2020 · 2768f3e · 2768f3e
1 parent 09818df
commit 2768f3e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/p2p/p2p.go b/p2p/p2p.go
@@ -187,7 +187,7 @@ func (t *Torrent) Download() ([]byte, error) {
  log.Println("Starting download for", t.Name)
  // Init queues for workers to retrieve work and send results
  workQueue := make(chan *pieceWork, len(t.PieceHashes))
- results := make(chan *pieceResult, len(t.PieceHashes))
+ results := make(chan *pieceResult)
  for index, hash := range t.PieceHashes {
  length := t.calculatePieceSize(index)
  workQueue <- &pieceWork{index, hash, length}