anchor.diff:  -spec terminate(term(), gen_changes_state()) -> ok.
   terminate(Reason, #{db_gateways := Gateways}) ->
       ?warning("~p terminating with reason ~p~n", [?MODULE, Reason]),
  -    Gateways = maps:values(Gateways),
  +    GatewayList = maps:values(Gateways),
       lists:foreach(
           fun(#{server := Pid}) ->
               Pid ! stop
  -        end, Gateways),
  +        end, GatewayList),
   
       ok.
   
  
positive.code: %% API
  
  %%--------------------------------------------------------------------
  %% @private
  %% @doc
  %% Starts changes stream with given callback function that is called on every change received from DB.
  %% @end
  
negative.code:         end, lists:zip(lists:seq(1, length(DBNodes)), DBNodes)),
      {ok, State#{db_gateways => maps:from_list(Gateways)}}.
  
  
  %%--------------------------------------------------------------------
  %% @doc
  