I'm really sorry Clark, but your exemple doesn't work better than mine ... Here's the result I got from your (last post) code : >python -u test_flow_clark.py [] >Exit code: 0 (and def "consumer()" should be "def consumer():" ) I'm on #twisted, I hope to see you Philippe