#NEWLINE# def _run_streaming_callback( self ) : #NEWLINE# #INDENT# if ( ( self . _streaming_callback is not None ) and self . _read_buffer_size ) : #NEWLINE# #INDENT# bytes_to_consume = self . _read_buffer_size #NEWLINE# if ( self . _read_bytes is not None ) : #NEWLINE# #INDENT# bytes_to_consume = min ( self . _read_bytes , bytes_to_consume ) #NEWLINE# self . _read_bytes -= bytes_to_consume #NEWLINE# #UNINDENT# self . _run_read_callback ( bytes_to_consume , True )