Minor code cleanup to concurrent flow processing

note: this still doesn't work... but it's not really
a priority to fix it right now.