             trySubmit()
 
 
-    _subscribeChannels: (channels, callback) -> # Subscribe to a redis pubsub channel and get a nodejs stream out
+    # Subscribe to a redis pubsub channel and get a nodejs stream out
+    _subscribeChannels: (channels, callback) ->
       # TODO: 2 refactors:
       #        - Make the redis observer we use here reusable
       #        - Reuse listens on channels

      # that is any better than the buffer implementation in nodejs streams themselves.
      stream._read = ->

      redisObserver = redisLib.createClient redis.port, redis.host, redis.options
      redisObserver.auth redis.auth_pass if redis.auth_pass

      open = true

      stream._id = nextStreamId++

  streams = {}
  nextStreamId = 0

  redisObserver = redisLib.createClient redis.port, redis.host, redis.options
  redisObserver.auth redis.auth_pass if redis.auth_pass
  redisObserver.setMaxListeners 0

  # Redis has different databases, which are namespaced separately. We need to
  # make sure our pubsub messages are constrained to the database where we
  # published the op.
  prefixChannel = (channel) -> "#{redis.selected_db || 0} #{channel}"
  getOpLogKey = (cName, docName) -> "#{cName}.#{docName} ops"
  getDocOpChannel = (cName, docName) -> "#{cName}.#{docName}"

