make the channel supplied to doProcess 'send only'

hashicorp · Aug 11, 2024 · 5446cc2 · 5446cc2
1 parent 7a72cf9
commit 5446cc2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/graph.go b/graph.go
@@ -72,7 +72,7 @@ func (g *graph) process(ctx context.Context, e *Event) (Status, error) {
 //     filter node's ID
 //   - the final node in a pipeline (a sink) finishes, and Status.complete contains
 //     the sink node's ID
-func (g *graph) doProcess(ctx context.Context, node *linkedNode, e *Event, statusChan chan Status, wg *sync.WaitGroup) {
+func (g *graph) doProcess(ctx context.Context, node *linkedNode, e *Event, statusChan chan<- Status, wg *sync.WaitGroup) {
 	defer wg.Done()
 
 	// Process the current Node