Added subscribeOnce method + tests