diff --git a/async/iface_queue.go b/async/iface_queue.go index fdc835e..73fb904 100644 --- a/async/iface_queue.go +++ b/async/iface_queue.go @@ -24,7 +24,7 @@ func manageQueue(send <-chan interface{}, receive chan<- interface{}) { } } else { select { - case receive <- front.Value.(interface{}): + case receive <- front.Value: queue.Remove(front) case value, ok := <-send: if ok {