StreamProcessor + unit test