@raymcdermott Regarding the "odd behaviours if I create a mult inside a function and then use it in a go loop” perhaps the issue is that the channel supplied to mult already have items that get dropped before any calls to tap? Per the spec “items received when there are no taps get dropped” so the pipeline has to be constructed before connecting to inflowing messages.

i'm pretty sure go and go-loop can't see beyond function definition boundaries