#NEWLINE# def put_all_records( self ) : #NEWLINE# #INDENT# 'Put all pending records in the Kinesis stream.' #NEWLINE# precs = self . _pending_records #NEWLINE# self . _pending_records = [ ] #NEWLINE# self . put_records ( precs ) #NEWLINE# self . total_records += len ( precs ) #NEWLINE# return len ( precs )