Stream processing added