diff --git a/queue.go b/queue.go index 216dd70..1084c29 100644 --- a/queue.go +++ b/queue.go @@ -97,7 +97,7 @@ func (lq *LoafleQueue) Close() { observer.Remove(lq.queueType, lq.eventChanel) } } -func NewLoafleQueue(eventType EventType, interval time.Duration) *LoafleQueue { +func NewQueue(eventType EventType, interval time.Duration) *LoafleQueue { items := make([]*item, 0) event := make(chan interface{}, 0) diff --git a/queue_test.go b/queue_test.go index 2b047f5..c86849e 100644 --- a/queue_test.go +++ b/queue_test.go @@ -6,8 +6,8 @@ import ( "testing" ) -func TestNewLoafleQueue(t *testing.T) { - lq := NewLoafleQueue(EVENT_TYPE, 5) +func TestNewQueue(t *testing.T) { + lq := NewQueue(EVENT_TYPE, 5) typeEvent := lq.StringType(EVENT_TYPE) observer.Notify(typeEvent, "data")