@async_enterable<EOL><INDENT>async def get_stream(self, *command_args, conn_type="<STR_LIT:I>", offset=<NUM_LIT:0>):<DEDENT>
reader, writer = await self.get_passive_connection(conn_type)<EOL>if offset:<EOL><INDENT>await self.command("<STR_LIT>" + str(offset), "<STR_LIT>")<EOL><DEDENT>await self.command(*command_args)<EOL>stream = DataConnectionThrottleStreamIO(<EOL>self,<EOL>reader,<EOL>writer,<EOL>throttles={"<STR_LIT:_>": self.throttle},<EOL>timeout=self.socket_timeout,<EOL>)<EOL>return stream<EOL>
: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`