code: async def _init_writer(self):
          
          async with self._initialization_lock:
              if not self.initialized:
                  self.stream = await aiofiles.open(
                      file=self.absolute_file_path,
                      mode=self.mode,
                      encoding=self.encoding,
                      loop=self.loop,
                  )
docs: Open the current base file with the (original) mode and encoding.
          Return the resulting stream.