fix log output end of stream in subscription engine

fix log output end of stream in subscription engine #103