Add with done - Githubissues

splunk / pipelines

Concurrent processing pipelines in Go.

MIT License

21 stars 8 forks source link

Closed kalexmills-splunk closed 2 years ago

kalexmills-splunk commented 2 years ago

Cleans up some overcomplicated code; simplifies the functional options API.
Adds pipelines.WithDone() and pipelines.WithWaitGroup() options for detecting the termination of all goroutines associated with one or more pipeline stages.