Cleanup code as we work towards deprecation / canonicalization 

With progress being made on the NodeJS and Go versions of streamer, as we get closer to publishing some real comparative benchmarks eventually, let's clean up the code syntax here a bit, as it's a total mess.

A conscious effort is being made to preserve all the **logic** of the original, warts  and all (a gazillion redis connections lolz).  Thus, only minor fixing up Ruby syntax and structure a bit so that it's more obvious what's being done, so people who want to understand the fundamental differences between the concurrency models used with the different streamer platforms will have an easier time following the code.

That said, let's not spend too long on it, as the likely scenario is that this code won't be in production anymore at some point in the future (although will always be useful to have in working order due to the workaround for Heroku connection-close issues).