def append_file(self, file):
self.files.append(file)<EOL>if self.transformer:<EOL><INDENT>future = asyncio.ensure_future(self.transformer.transform(file))<EOL>future.add_done_callback(self.handle_transform)<EOL><DEDENT>
Append a new file in the stream.