def write(self, buf, full=False, timeout=None): """Write data in buf to stdin of pipe. See 'write' method of AsyncFile for details. """ yield self.stdin.write(buf, full=full, timeout=timeout)