Closure should support now stream processing