peerreader

Feb 27, 2019

Changes in this version

+ const MaxBlockSize

Feb 19, 2019

Changes in this version

type Piece

+ Buffer bufferpool.Buffer

Feb 18, 2019

Changes in this version

type Piece

+ func (p *Piece) ReleaseBuffer()

Jan 25, 2019

Changes in this version

+ var PiecePool = sync.Pool

+ type PeerReader struct

+ func New(conn net.Conn, l logger.Logger, pieceTimeout time.Duration, bufferSize int, ...) *PeerReader

+ func (p *PeerReader) Done() chan struct{}

+ func (p *PeerReader) Messages() <-chan interface{}

+ func (p *PeerReader) Run()

+ func (p *PeerReader) Stop()

+ type Piece struct

+ Data []byte