From d597bc2cd9a306d3434ba8b963599b5a3e4caf45 Mon Sep 17 00:00:00 2001 From: Daniil Gentili Date: Wed, 27 Sep 2023 12:12:43 +0200 Subject: [PATCH] More logs --- consumer/multiplexer/multiplexer.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consumer/multiplexer/multiplexer.go b/consumer/multiplexer/multiplexer.go index bb98f0e8..54b287ca 100644 --- 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() })