anchor.diff:  
   %% @private
   -spec terminate(term(), state_t()) -> term().
  -terminate(_Reason, #state{socket=Socket}) ->
  +terminate(Reason, #state{socket=Socket}) ->
  +    lager:info("Process ~p terminating for reason ~p...", [self(), Reason]),
       ok = partisan_peer_connection:close(Socket),
       ok.
   
  
positive.code: -spec handle_cast(term(), state_t()) -> {noreply, state_t()}.
  %% @private
  handle_cast({send_message, Message}, #state{channel=_Channel, socket=Socket}=State) ->
      case get({?MODULE, egress_delay}) of
          0 ->
              ok;
  
negative.code: 
              {ok, #state{from=From, listen_addr=ListenAddr, channel=Channel, socket=Socket, peer=Peer}};
          Error ->
              lager:warning("Pid ~p is unable to connect to ~p due to ~p", [self(), Peer, Error]),
              {stop, normal}
      end.
  
  