code: async def get_stream(self, *command_args, conn_type="I", offset=0):
          
          reader, writer = await self.get_passive_connection(conn_type)
          if offset:
              await self.command("REST " + str(offset), "350")
          await self.command(*command_args)
          stream = DataConnectionThrottleStreamIO(
              self,
              reader,
              writer,
              throttles={"_": self.throttle},
              timeout=self.socket_timeout,
          )
          return stream
docs: :py:func:`asyncio.coroutine`
  
          Create :py:class:`aioftp.DataConnectionThrottleStreamIO` for straight
          read/write io.
  
          :param command_args: arguments for :py:meth:`aioftp.Client.command`
  
          :param conn_type: connection type ("I", "A", "E", "L")
          :type conn_type: :py:class:`str`
  
          :param offset: byte offset for stream start position
          :type offset: :py:class:`int`
  
          :rtype: :py:class:`aioftp.DataConnectionThrottleStreamIO`