I've been trying to unit test the subscribe function of this service. And looking at the code cove