       added: (id, fields) =>
         return if _.isEmpty fields
 
-        @updateSource id, fields
+        @_updateSource id, fields
 
       changed: (id, fields) =>
-        @updateSource id, fields
+        @_updateSource id, fields
 
       removed: (id) =>
-        @removeSource id
+        @_removeSource id
 
   updatedWithValue: (id, value) =>
     unless _.isObject(value) and _.isString(value._id)


    @Meta.collection.find({}, fields: sourceFields).observeChanges
      added: (id, fields) =>
        @sourceUpdated id, fields

      changed: (id, fields) =>
        @sourceUpdated id, fields

setupObservers = ->
  setupTargetObservers = (fields) ->


    @sourceCollection.update selector, update, multi: true

  _removeSource: (id) =>
    selector = {}
    selector["#{ @sourcePath }._id"] = id

