gistfile1.py

        while True:
            # XXX need to yield to 
            bytes = self.message_spool_file.read(1024)
            if not bytes:
                for protocol in protocols:
                    protocol.finish()
                break

            def worker(protocol):
                print "*"*30, "Writing %s bytes" % (len(bytes),)
                protocol.write(bytes)
                
            task = cooperate(worker(protocol) for protocol in protocols)
            task.start()
            yield task.whenDone()