refactor(queue_unbounded): inbountLen -> inboundLen (#3666)
This commit is contained in:
@@ -28,8 +28,8 @@ func (q *UnboundedQueue) Consume(fn func([]string)) {
|
||||
|
||||
if len(q.outbound) == 0 {
|
||||
q.inboundLock.Lock()
|
||||
inbountLen := len(q.inbound)
|
||||
if inbountLen > 0 {
|
||||
inboundLen := len(q.inbound)
|
||||
if inboundLen > 0 {
|
||||
t := q.outbound
|
||||
q.outbound = q.inbound
|
||||
q.inbound = t
|
||||
|
||||
Reference in New Issue
Block a user