-
Notifications
You must be signed in to change notification settings - Fork 48
Open
Description
package event
import (
"testing"
"github.com/davecgh/go-spew/spew"
"github.com/joncrlsn/dque"
)
func TestName(t *testing.T) {
q, err := dque.NewOrOpen("q", ".", 2, func() interface{} {
return new(string)
})
if err != nil {
t.Fatal(err)
}
defer q.Close()
if err := q.TurboOn(); err != nil {
t.Fatal(err)
}
if err := q.Enqueue("1"); err != nil {
t.Fatal(err)
}
if err := q.Enqueue("2"); err != nil {
t.Fatal(err)
}
if err := q.Enqueue("3"); err != nil {
t.Fatal(err)
}
if err := q.Enqueue("4"); err != nil {
t.Fatal(err)
}
if err := q.Enqueue("5"); err != nil {
t.Fatal(err)
}
for {
item, err := q.Dequeue()
if err == dque.ErrEmpty {
return
}
if err != nil {
t.Fatal(err)
}
spew.Dump(item)
}
}
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels
