anchor.diff:  
   %% Handle stream crashes
   %% todo: ensure VFS-1877 is resolved (otherwise it probably isn't working)
  +handle({'EXIT', _, stream_replaced}) ->
  +    ok;
   handle({'EXIT', Stream, Reason}) ->
       case state_get(changes_stream) of
           Stream ->
  
positive.code: %% Append change to given queue
  handle({QueueKey, #change{seq = Seq, doc = #document{key = Key, rev = Rev} = Doc} = Change}) ->
      ?debug("[ DBSync ] Received change on queue ~p with seq ~p: ~p", [QueueKey, Seq, Doc]),
      dbsync_utils:temp_put(last_change, erlang:monotonic_time(milli_seconds), 0),
      Rereplication = QueueKey =:= global andalso dbsync_utils:temp_get({replicated, Key, Rev}) =:= true,
      case {has_sync_context(Doc), Rereplication} of
          {true, false} ->
  
negative.code:     DBSyncPid = whereis(?MODULE),
      case self() of
          DBSyncPid ->
              DoUpdate(undefined);
          _ ->
              %% Just run in worker_host's process on any key
              worker_host:state_update(dbsync_worker, undefined, DoUpdate)
      end.
  
  
  