anchor.diff:  
       {Props} = to_json_term(Value),
       Doc = {[{<<"_revisions">>, {[{<<"ids">>, Ids}, {<<"start">>, Start}]}}, {<<"_rev">>, rev_info_to_rev(Revs)}, {<<"_id">>, to_driver_key(Bucket, Key)} | Props]},
  -    case db_run(couchbeam, save_doc, [Doc,[{<<"new_edits">>, <<"false">>}] ++ ?DEFAULT_DB_REQUEST_TIMEOUT_OPT], 3) of
  +    case db_run(couchbeam, save_doc, [Doc, [{<<"new_edits">>, <<"false">>}] ++ ?DEFAULT_DB_REQUEST_TIMEOUT_OPT], 3) of
           {ok, {_}} ->
               {ok, Key};
           {error, conflict} ->
  
positive.code:                                     Acc %% Trash entry, skipping
                              end
                          catch
                              _:_ ->
                                  Acc %% Invalid entry, skipping
                          end
                      end, AccIn, Rows)
                  catch
                      {abort, RetAcc} ->
                          RetAcc %% Provided function requested end of stream, exiting loop
                  end,
              {ok, Ret};
          {error, Reason} ->
              {error, Reason}
  
negative.code:         <<"views">> => maps:from_list(lists:map(
              fun(#model_config{name = ModelName}) ->
                  BinModelName = atom_to_binary(ModelName, utf8),
                  {BinModelName, #{<<"map">> => <<"function(doc) { if(doc['", ?RECORD_MARKER, "'] == \"", BinModelName/binary, "\") emit(doc['", ?RECORD_MARKER, "'], doc); }">>}}
              end, Models))
      }),
      {ok, _} = db_run(couchbeam, save_doc, [Doc], 5),
  