overflow_backup_2018_0455/queue_go
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test code push

Browse Source
This commit is contained in:
geek 2017-04-26 16:04:28 +09:00
parent 5dfe829b88
commit 50f80fb220
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
queue.go
View File

@ -97,7 +97,7 @@ func (lq *LoafleQueue) Close() {
observer.Remove(lq.queueType, lq.eventChanel) 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) items := make([]*item, 0)
event := make(chan interface{}, 0) event := make(chan interface{}, 0)

4
queue_test.go
View File

@ -6,8 +6,8 @@ import (
"testing" "testing"
) )
func TestNewLoafleQueue(t *testing.T) { func TestNewQueue(t *testing.T) {
lq := NewLoafleQueue(EVENT_TYPE, 5) lq := NewQueue(EVENT_TYPE, 5)
typeEvent := lq.StringType(EVENT_TYPE) typeEvent := lq.StringType(EVENT_TYPE)
observer.Notify(typeEvent, "data") observer.Notify(typeEvent, "data")