fix(async): change the channel type on pool.Start (#54)

snivilised · Aug 30, 2023 · 0c0ec2b · 0c0ec2b
1 parent b2e997d
commit 0c0ec2b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/async/worker-pool.go b/async/worker-pool.go
@@ -97,15 +97,15 @@ func (p *WorkerPool[I, O]) composeID() WorkerID {
 
 func (p *WorkerPool[I, O]) Start(
 	ctx context.Context,
-	outputsChOut OutputStreamW[O],
+	outputsChOut OutputStream[O],
 ) {
 	p.run(ctx, p.private.workersJobsCh, outputsChOut)
 }
 
 func (p *WorkerPool[I, O]) run(
 	ctx context.Context,
 	forwardChOut JobStreamW[I],
-	outputsChOut OutputStreamW[O],
+	outputsChOut OutputStream[O],
 ) {
 	defer func() {
 		if outputsChOut != nil {
@@ -171,7 +171,7 @@ func (p *WorkerPool[I, O]) run(
 func (p *WorkerPool[I, O]) spawn(
 	ctx context.Context,
 	jobsChIn JobStreamR[I],
-	outputsChOut OutputStreamW[O],
+	outputsChOut OutputStream[O],
 	finishedChOut FinishedStreamW,
 ) {
 	cancelCh := make(CancelStream, 1)

diff --git a/async/worker.go b/async/worker.go
@@ -9,7 +9,7 @@ type worker[I any, O any] struct {
 	id            WorkerID
 	exec          ExecutiveFunc[I, O]
 	jobsChIn      JobStreamR[I]
-	outputsChOut  OutputStreamW[O]
+	outputsChOut  OutputStream[O]
 	finishedChOut FinishedStreamW
 
 	// this might be better replaced with a broadcast mechanism such as sync.Cond