(t *testing.T)
| 28 | } |
| 29 | |
| 30 | func TestSyncQueue(t *testing.T) { |
| 31 | q := NewQueue(1, 2) |
| 32 | q.Run() |
| 33 | defer q.Terminate() |
| 34 | |
| 35 | sjob := NewSyncJob("foo", func(v interface{}) (interface{}, error) { |
| 36 | return fmt.Sprintf("%s_bar", v), nil |
| 37 | }) |
| 38 | q.Push(sjob) |
| 39 | |
| 40 | result := <-sjob.Wait() |
| 41 | if err := sjob.Error(); err != nil { |
| 42 | t.Error(err.Error()) |
| 43 | } |
| 44 | |
| 45 | if !reflect.DeepEqual(result, "foo_bar") { |
| 46 | t.Error(result) |
| 47 | } |
| 48 | } |
| 49 | |
| 50 | func ExampleQueue() { |
| 51 | q := NewQueue(1, 10) |