when reaching full buffer, flush and process latest message right then instead of requeuing, to ensure order of msgs
Merge pull request #23 from AlexandreBeaulne/dev

stream process