Extend for stream processing