#NEWLINE# def rcptto( self , address ) : #NEWLINE# #INDENT# 'Sends the RCPT command with the ``address``. If the server\n        does *not* support PIPELINING, the returned reply object is\n        populated immediately.\n\n        :param address: The sender address to send.\n        :param data_size: Optional size of the message body.\n        :returns: |Reply| object that will be populated with the response\n                  once a non-pipelined command is called, or if the server does\n                  not support PIPELINING.\n\n        ' #NEWLINE# rcptto = Reply ( command = b'RCPT' ) #NEWLINE# self . reply_queue . append ( rcptto ) #NEWLINE# command = b'' . join ( ( b'RCPT TO:<' , self . _encode ( address ) , b'>' ) ) #NEWLINE# self . io . send_command ( command ) #NEWLINE# if ( 'PIPELINING' not in rcptto . extensions ) : #NEWLINE# #INDENT# self . _flush_pipeline ( ) #NEWLINE# #UNINDENT# return rcptto