diff --git a/async/worker-pool.go b/async/worker-pool.go
index a6a6eaf..0654d4e 100644
--- a/async/worker-pool.go
+++ b/async/worker-pool.go
@@ -97,7 +97,7 @@ 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)
 }
@@ -105,7 +105,7 @@ func (p *WorkerPool[I, O]) Start(
 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
index d9351f8..eb99395 100644
--- 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