anchor.diff:                                      Acc %% Trash entry, skipping
                               end
                           catch
  +                            {abort, RetAcc} ->
  +                                RetAcc; %% Provided function requested end of stream, exiting loop
                               _:_ ->
                                   Acc %% Invalid entry, skipping
                           end
  -                    end, AccIn, Rows)
  -                catch
  -                    {abort, RetAcc} ->
  -                        RetAcc %% Provided function requested end of stream, exiting loop
  -                end,
  +                    end, AccIn, Rows),
               {ok, Ret};
           {error, Reason} ->
               {error, Reason}
  
positive.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),
  
negative.code: 
      {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
          {ok, {_}} ->
              {ok, Key};
          {error, conflict} ->
  