code: def append_file(self, file):
  		
  		self.files.append(file)
  
  		if self.transformer:
  			future = asyncio.ensure_future(self.transformer.transform(file))
  			future.add_done_callback(self.handle_transform)
docs: Append a new file in the stream.