twitter clone with asynch via futures/observables/actors using redis pubsub and geared towards broadcasting streams generated by machines