func newPubQueue() *pubQueue {
	sq := &pubQueue{
		initCap: initialCapacity,
		nodes:   make([]preparedPub, initialCapacity),
	}
	sq.cond = sync.NewCond(&sq.mu)
	return sq
}
// New ByteQueue returns a new preparedPub queue with initial capacity.
New ByteQueue returns a new preparedPub queue with initial capacity.
// New ByteQueue returns a new preparedPub queue with initial capacity .
func newPubQueue() *pubQueue {
	sq := &pubQueue{
		initCap: initialCapacity,
		nodes:   make([]preparedPub, initialCapacity),
	}
	sq.cond = sync.NewCond(&sq.mu)
	return sq
}
func newPubQueue ( ) * pubQueue { sq := & pubQueue { initCap : initialCapacity , nodes : make ( [ ] preparedPub , initialCapacity ) , } sq . cond = sync . NewCond ( & sq . mu ) return sq }
New ByteQueue returns a new preparedPub queue with initial capacity.
New ByteQueue returns a new preparedPub queue with initial capacity .