Skip to content

Commit

Permalink
fixed examples
Browse files Browse the repository at this point in the history
  • Loading branch information
ilkamo committed Dec 26, 2024
1 parent d54e8d4 commit d16b32d
Show file tree
Hide file tree
Showing 2 changed files with 45 additions and 40 deletions.
31 changes: 13 additions & 18 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -53,11 +53,8 @@ Each task is a function that returns a slice of items and an error:
```go
p := polipo.NewPolipo[TaskResult]()

p.AddTask(func () ([]TaskResult, error) {
return []TaskResult{
{ID: 1, Name: "Task1"},
{ID: 2, Name: "Task2"},
}, nil
err := p.AddTask(func () (TaskResult, error) {
return TaskResult{ID: 1, Name: "Task1"}, nil
})
```

Expand Down Expand Up @@ -104,19 +101,17 @@ func main() {
ctx := context.TODO()
p := polipo.NewPolipo[TaskResult]()

p.AddTask(func() ([]TaskResult, error) {
return []TaskResult{
{ID: 1, Name: "Task1"},
{ID: 2, Name: "Task2"},
}, nil
})

p.AddTask(func() ([]TaskResult, error) {
return []TaskResult{
{ID: 3, Name: "Task3"},
{ID: 4, Name: "Task4"},
}, nil
})
if err := p.AddTask(func() (TaskResult, error) {
return TaskResult{ID: 1, Name: "Task1"}, nil
}); err != nil {
panic("could not add task") // don't panic in production code
}

if err := p.AddTask(func() (TaskResult, error) {
return TaskResult{ID: 2, Name: "Task2"}, nil
}); err != nil {
panic("could not add task")
}

results, err := p.Do(ctx)
if err != nil {
Expand Down
54 changes: 32 additions & 22 deletions examples/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,35 +9,45 @@ import (
)

type TaskResult struct {
FishName string
Fishes []string
}

func main() {
p := polipo.NewPolipo[TaskResult]()

p.AddTask(func() ([]TaskResult, error) {
return []TaskResult{
{FishName: "Salmon"},
{FishName: "Tuna"},
{FishName: "Trout"},
{FishName: "Cod"},
if err := p.AddTask(func() (TaskResult, error) {
return TaskResult{
Fishes: []string{
"Salmon",
"Tuna",
"Trout",
"Cod",
},
}, nil
})

p.AddTask(func() ([]TaskResult, error) {
return nil, nil
})

p.AddTask(func() ([]TaskResult, error) {
return []TaskResult{
{FishName: "Swordfish"},
{FishName: "Marlin"},
{FishName: "Barracuda"},
{FishName: "Mahi Mahi"},
{FishName: "Wahoo"},
{FishName: "Kingfish"},
}); err != nil {
panic(err) // this is just an example, don't panic in production
}

if err := p.AddTask(func() (TaskResult, error) {
return TaskResult{}, nil
}); err != nil {
panic(err)
}

if err := p.AddTask(func() (TaskResult, error) {
return TaskResult{
Fishes: []string{
"Swordfish",
"Marlin",
"Barracuda",
"Mahi Mahi",
"Wahoo",
"Kingfish",
},
}, nil
})
}); err != nil {
panic(err)
}

ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel()
Expand Down

0 comments on commit d16b32d

Please sign in to comment.