Support parallel processing of stream