arthur/server.py
def write_items(cls, writer, items_generator):
        """Write items to the queue

        :param writer: the writer object
        :param items_generator: items to be written in the queue
        """
        while True:
            items = items_generator()
            writer.write(items)
            time.sleep(1)
def write_items(cls, writer, items_generator):
        while True:
            items = items_generator()
            writer.write(items)
            time.sleep(1)
def write_items ( cls , writer , items_generator ) : while True : items = items_generator ( ) writer . write ( items ) time . sleep ( 1 )
Write items to the queue

        :param writer: the writer object
        :param items_generator: items to be written in the queue
Write items to the queue