 
   # Subscribe to the `requests` and `responses` channels.
   listen: ->
-    @_requests_channel.listen (source, keys) =>
-      @_requested source, keys
+    @_requests_channel.listen (source, keys) => @_requested source, keys
     @_responses_channel.listen (ch, str) => @_responded str
 
   # Send quit signals to the work queues.

      @_recover()
    else
      console.log "Hmm, the doctor couldn't find anything amiss..." if @_verbose
  
  # Recover from a stuck process.
  _recover: ->
    if @doc.recoverable()

      when undefined then @_reqs.push key
    (@deps[key] ?= []).push source
    @_dependency_count[source]++

  # Take the unmet dependencies from the latest request and push
  # them onto the `jobs` queue.
  _request_dependencies: ->
