Hey 
I think I’m trying to do something similar to what you did (see my recent question). Each of your downstream flows transforms things, so how can you pass things through? You mention “pass the original input through to the next ‘downstream flow’”, so what does that look like with your original example?
Also, if you look at my example I’m using into_specs to create supervised children of the original flow process, which seems like it should do exactly what I (we? ) want, but I don’t know how to make a flow which doesn’t start with a Producer (except by using from_stages, I guess, but that doesn’t seem to be working…)
