[Dave Scheck]

I went through the exercise of making a test program and got it to work. It's based around the same model that you have. The loop in the middle waits for the input and enqueues it to the necessary queue. The other two loops are waiting on their dequeue and will update the corresponding output when data is seen. This seems to work as expected. See the attached diagram

My example used just an integer as input, but I tried passing a cluster around to make sure there wasn't something different with that, but it worked just fine.

Have you tried to run with the execution highlighted to make sure your loops are running as expected? I had a bug when testing that caused only one loop to run (made the mistake of having a stop control from one loop tied to the end condition of the other while loops). Maybe you're hitting something silly like that?