feat: add Responses() method

proullon · May 14, 2020 · 3e091d5 · 3e091d5
1 parent 5e458e9
commit 3e091d5
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/workerpool.go b/workerpool.go
@@ -182,6 +182,11 @@ func New(jobfnc JobFnc, opts ...OptFunc) (*WorkerPool, error) {
 	return wp, nil
 }
 
+// Responses returns Response channel containing all Job returned values
+func (wp *WorkerPool) Responses() chan Response {
+	return wp.ReturnChannel
+}
+
 // VelocityValues returns map of recorded velocity for each used velocity percentil
 func (wp *WorkerPool) VelocityValues() map[int]float64 {
 	c := make(map[int]float64)