anchor.diff:  
   %% Debug API
   -export([ debug/2
  +        , no_debug/1
           , get_sockets/1
           ]).
   
  
positive.code:         , handle_info/2
          , terminate/2
          , code_change/3
          ]).
  
  %%%_* Includes -----------------------------------------------------------------
  
negative.code:       {noreply, State0}
    end;
  handle_info({msg, Leader, CorrId, #produce_response{}}, State0) ->
    {value, {_, {CorrId, FromList}}, Pending} =
      lists:keytake(Leader, 1, State0#state.pending),
    lists:foreach(fun({Pid, Ref}) ->
                      Pid ! {{Ref, self()}, ack}
                  end, FromList),
    {ok, State} = maybe_send(Leader, State0#state{pending = Pending}),
    {noreply, State};
  handle_info({'EXIT', Pid, Reason}, State) ->
    Sockets = lists:keydelete(Pid, #socket.pid, State#state.sockets),
  