Implement the abstracted reduce() (aka foldLeft()) method for primitive streams to correct the mistake of the Java folks who chose to omit it.
Factor out the check that the stream is sequential from all the reduce functions.
Switch to using the new reduce() utility function for streams and primitives.
More testing for real time queues.