Created StreamProcessor and other utility classes which are useful for
stream processing.