anchor.diff:          %% Schedule message for redelivery.
           RetryOptions = Options#{retransmission => true},
   
  -        gen_server:cast(?MODULE, {forward_message, From, Name, Channel, Clock, PartitionKey, ServerRef, Message, RetryOptions})
  +        gen_server:cast(
  +            ?MODULE,
  +            {
  +                forward_message,
  +                From,
  +                Node,
  +                Channel,
  +                Clock,
  +                PartitionKey,
  +                ServerRef,
  +                Message,
  +                RetryOptions
  +            }
  +        )
       end,
   
       {ok, Outstanding} = partisan_acknowledgement_backend:outstanding(),
   
       case partisan_config:get(replaying, false) of
           false ->
  -            %% Fire all pre-interposition functions, and then deliver, preserving serial order of messages.
  +            %% Fire all pre-interposition functions, and then deliver,
  +            %% preserving serial order of messages.
               lists:foreach(RetransmitFun, Outstanding);
           true ->
  -            %% Allow the system to proceed, and the message will be delivered once pre-interposition is done.
  -            lists:foreach(fun(OutstandingMessage) ->
  -                spawn_link(fun() ->
  -                    RetransmitFun(OutstandingMessage)
  -                end)
  -            end, Outstanding)
  +            %% Allow the system to proceed, and the message will be delivered
  +            %% once pre-interposition is done.
  +            lists:foreach(
  +                fun(OutstandingMessage) ->
  +                    spawn_link(fun() ->
  +                        RetransmitFun(OutstandingMessage)
  +                    end)
  +                end,
  +                Outstanding
  +            )
       end,
   
       %% Reschedule retransmission.
  
positive.code: handle_call(Event, _From, State) ->
      ?LOG_WARNING(#{description => "Unhandled call event", event => Event}),
      {reply, ok, State}.
  
  %% @private
  -spec handle_cast(term(), t()) -> {noreply, t()}.
  
negative.code:             %% notify subscribers
              up(NodeSpec, State0),
  
              ok = case Membership == Membership0 of
                  true ->
                      ok;
                  false ->
                      partisan_peer_service_events:update(Membership)
              end,
  
  