Added unit test for StreamConsumer