More implementation towards handling the streams from processes