refactor pulling from tweeter stream into a service