             callback err
 
 
-    runReplication: (fromRemote, toRemote, continuous, rebuildFs, fetchBinary, callback) ->
+    runReplication: (fromRemote, toRemote, continuous,
+                     rebuildFs, fetchBinary, callback) ->
         deviceName = config.getDeviceName()
         continuous ?= false
         rebuildFs ?= false

            else
                callback null

        .on 'error', (err) ->
            log.error err
            callback err

                    filesystem.watchingLocked = false
                    callback null

        onChange = (info) ->
            changeMessage = "DB change: #{info.change.docs_written} doc(s) written"
            if info.direction
                # Specify direction
