[streaming] Updated operators for better mutability handling