Fixed a problem with the process method's stream subscription constructed every time the method was called