func (q *pubQueue) Closed() bool {
	q.mu.RLock()
	c := q.closed
	q.mu.RUnlock()
	return c
}
// Closed returns true if the queue has been closed
// The call cannot guarantee that the queue hasn't been
// closed while the function returns, so only "true" has a definite meaning.
Closed returns true if the queue has been closed
The call cannot guarantee that the queue hasn't been
closed while the function returns, so only "true" has a definite meaning.
// Closed returns true if the queue has been closed // The call cannot guarantee that the queue hasn ' t been // closed while the function returns so only " true " has a definite meaning .
func (q *pubQueue) Closed() bool {
	q.mu.RLock()
	c := q.closed
	q.mu.RUnlock()
	return c
}
func ( q * pubQueue ) Closed ( ) bool { q . mu . RLock ( ) c := q . closed q . mu . RUnlock ( ) return c }
Closed returns true if the queue has been closed
The call cannot guarantee that the queue hasn't been
closed while the function returns, so only "true" has a definite meaning.
Closed returns true if the queue has been closed The call cannot guarantee that the queue hasn ' t been closed while the function returns so only " true " has a definite meaning .