Move SubscribeToStreamUtil to rests.services.impl