code: def output(self, chunk):
          
          if chunk is not None:
              for queue in self.output_queues:
                  queue.put(chunk)
docs: Dispatch the given Chunk onto all the registered output queues.
  
          If the chunk is None, it is silently ignored.