More logs

zoonru · Sep 27, 2023 · d597bc2 · d597bc2
1 parent f5e7c0b
commit d597bc2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer/multiplexer/multiplexer.go b/consumer/multiplexer/multiplexer.go
@@ -125,6 +125,7 @@ func (m *T) WireUp(output Out, assigned []int32) {
 	// Stop inputs that are not assigned anymore.
 	for p, in := range m.inputs {
 		if !slices.Contains(assigned, p) {
+			in := in
 			actor.Spawn(m.actDesc.NewChild(fmt.Sprintf("stop_unassigned.p%d", p)), &wg, func() {
 				in.Stop()
 			})