#NEWLINE# def _send_flow( self , active ) : #NEWLINE# #INDENT# '\n        Send a flow control command.\n        ' #NEWLINE# args = Writer ( ) #NEWLINE# args . write_bit ( active ) #NEWLINE# self . send_frame ( MethodFrame ( self . channel_id , 20 , 20 , args ) ) #NEWLINE# self . channel . add_synchronous_cb ( args . _recv_flow_ok )