import reader
import writer
import bucket

def main():
   r = reader.Reader(reader.StdinReader())
   r = reader.Reader(reader.RandomReader())
   w = writer.Writer(writer.MultiWriter(
      #writer.StdoutWriter(),
      writer.PyAutoGUIWriter(),
   ))
   bkt = bucket.Bucket()
   for line in r.read():
      latest_bkt = bucket.Bucket()
      if latest_bkt.name != bkt.name:
         picked = bkt.pick_n(2)
         w.write(picked)
         bkt = latest_bkt
      bkt.push(line)
   print("closing writer")
   w.close()

if __name__ == "__main__":
   main()