#NEWLINE# @ retry ( 9 , Exception , 0.01 , 'pypet.retry' ) #NEWLINE# def _receive_data( self ) : #NEWLINE# #INDENT# 'Gets data from pipe' #NEWLINE# while True : #NEWLINE# #INDENT# while ( ( len ( self . _buffer ) < data . max_size ) and self . conn . poll ( ) ) : #NEWLINE# #INDENT# data = self . _read_chunks ( ) #NEWLINE# if ( data is not None ) : #NEWLINE# #INDENT# self . _buffer . append ( data ) #NEWLINE# #UNINDENT# #UNINDENT# if ( len ( self . _buffer ) > 0 ) : #NEWLINE# #INDENT# return self . _buffer . popleft ( )