Function newFIFOQueue

internal/p2p/queue.go:38–43

(size int)

}

func newFIFOQueue(size int) queue {
	return &fifoQueue{
		queueCh: make(chan Envelope, size),
		closer:  tmsync.NewCloser(),
	}
}

func (q *fifoQueue) enqueue() chan<- Envelope {
	return q.queueCh