stream process

when reaching full buffer, flush and process latest message right thenwhen reaching full buffer, flush and process latest message right then instead of requeuing, to ensure order of msgs