#NEWLINE# def unblock( self ) : #NEWLINE# #INDENT# ' Allow data through, and flush buffers ' #NEWLINE# self . _currently_blocked = False #NEWLINE# while ( not self . _send_queue . empty ( ) ) : #NEWLINE# #INDENT# data = self . _send_queue . get ( ) #NEWLINE# self . _actual_send ( self ) #NEWLINE# #UNINDENT# while ( not self . _receive_queue . empty ( ) ) : #NEWLINE# #INDENT# data = self . _receive_queue . get ( ) #NEWLINE# self . _actual_receive ( data )