anchor.diff:  %%--------------------------------------------------------------------
   -spec state_put(Key :: term(), Value :: term()) -> ok.
   state_put(Key, Value) ->
  -    {ok, _} = dbsync_state:save(#document{key = Key, value = #dbsync_state{entry = Value}}),
  +    {ok, _} = dbsync_state:save(#document{key = {dbsync_state, Key}, value = #dbsync_state{entry = Value}}),
       ok.
   
   %%--------------------------------------------------------------------
  
positive.code: %%--------------------------------------------------------------------
  -spec state_get(Key :: term()) -> Value :: term().
  state_get(Key) ->
      case dbsync_state:get(Key) of
          {ok, #document{value = #dbsync_state{entry = Value}}} ->
              Value;
          {error, {not_found, _}} ->
  
negative.code:                     ?info("[ DBSync ] Flush loop is too fast, breaking this one."),
                      throw({too_many_flush_loops, {flush_queue, QueueKey}});
                  _ ->
                      dbsync_utils:temp_put(last_global_flush, CTime, 0),
                      ensure_global_stream_active()
              end;
          _ -> ok
      end,
  