Use the existing fromStream() function instead of doing the reduce() again.
One more bug fix this time in the exec() method.
Test file for real time queues.