Fixed several c/p and logic errors in the various queued stream implementations.
Fixed several c/p and logic errors in the various queued stream implementations.

SkewedAspect/precursors-server,SkewedAspect/precursors-server,SkewedAspect/precursors-server,SkewedAspect/precursors-server