Queue object for storing requested pieces
type Queue struct {
Choked bool
// contains filtered or unexported fields
}
func NewQueue(torrent parser.TorrentFile) (queue *Queue)
NewQueue returns a fresh pointer to a Queue object
func (queue *Queue) Dequeue() error
Dequeue removes first piece block
func (queue *Queue) Enqueue(pieceIndex uint32) (err error)
Enqueue adds a piece to queue
func (queue *Queue) Length() int
Length returns length of queue
func (queue *Queue) Peek() (block parser.PieceBlock, err error)
Peek returns first pieceblock