Temporarily eliminates the continuous polling of the "slow" data.
Adjusts for filtering arrays of bytes.  Reinstitutes slow data polling.
Requests one page of slow data every second; slowing the rate.
Warn if flow control messages are seen
Adds a temporary check to see if the InputStreamPartitionBuffers are being drained.
Processing of slow data is byte wise and the processing thread is often in the buffer's monitor which *could* be holding up adds to the slow data buffer .. which could then in turn hold up adds to the fast data buffer.  The BufferedInputStream here is meant to drain the slow data buffer more often so it's lock can stay relinquished.
Drastic simplification of InputStream partitioning
Buffering went out of control!  Reduce it.
Customizes the PipedInputStream/PipedOutputStream to immediately awaken a blocked read() upon receive() of new data.
Tiny efficiency gain when writing SampleArrays.
speed up slow data requests again
Back to NO requests of slow data to ensure i haven't broken anything.
process fast data on the main partitioning thread
assigned wrong bit mask to wrong partition
where did the fast bytes go?
eliminate erroneous extension (of sign)
Trying really hard to increase determinism.  Now emits on clock (Every 250ms) instead of emitting whenever the batch buffer fills.
a worthwhile unit test of custom int parsing routine
fixed alarm mark/clear
Allow different sample emission intervals