Unit tests for queue input stream