internal

Aug 2, 2020

Changes in this version

+ var ErrIsClosed = errors.New("is closed")

+ var ErrIsFull = errors.New("is full")

+ type Queue struct

+ func NewQueue(cap int) *Queue

+ func (q *Queue) Close()

+ func (q *Queue) Push(data []byte) error

+ func (q *Queue) Read() <-chan []byte

+ type Signal chan struct

+ func (s Signal) Send()