def METHOD_NAME(self):
    """test write + worker.abort() on read to reuse FDs"""
    task = task_self()
    fanout = task.info("fanout")
    try:
        task.set_info("fanout", 1)
        eh = AbortOnReadHandler()
        for i in range(10):
            worker = task.shell("echo ok; sleep 1", handler=eh)
            worker.write("OK\n")
            self.assert_(worker is not None)
        task.resume()
    finally:
        task.set_info("fanout", fanout)