This commit is contained in:
geek 2017-04-27 15:35:35 +09:00
parent 55f8a0d30f
commit 430e993a68

View File

@ -89,6 +89,7 @@ func (lq *LoafleQueue) Close() {
if lq.eventChanel != nil {
observer.Remove(lq.queueType, lq.eventChanel)
}
lq.items = nil
}
func NewQueue(eventType string, interval time.Duration, senderChanel chan interface{}) *LoafleQueue {
items := make([]*Item, 0)