anchor.diff:      Defaults = [
           {mode,                             undefined}],
       [Mode] = cloudi_proplists:take_values(Defaults, Args),
  -    if
  +    NewMode = if
           Mode =:= reply ->
               cloudi_service:subscribe(Dispatcher,
  -                                     ?SERVICE_SUFFIX1);
  +                                     ?SERVICE_SUFFIX1),
  +            reply;
  +        Mode =:= reply_x4 ->
  +            cloudi_service:subscribe(Dispatcher,
  +                                     ?SERVICE_SUFFIX1),
  +            cloudi_service:subscribe(Dispatcher,
  +                                     ?SERVICE_SUFFIX1),
  +            cloudi_service:subscribe(Dispatcher,
  +                                     ?SERVICE_SUFFIX1),
  +            cloudi_service:subscribe(Dispatcher,
  +                                     ?SERVICE_SUFFIX1),
  +            reply;
           Mode =:= init_send_sync ->
               {ok, _, _} = cloudi_service:send_sync(Dispatcher,
                                                     ?SERVICE_PREFIX1 ++
                                                     ?SERVICE_SUFFIX1,
  -                                                  <<"request">>);
  +                                                  <<"request">>),
  +            undefined;
           Mode =:= init_send_async_recv ->
               {ok, TransId} = cloudi_service:send_async(Dispatcher,
                                                         ?SERVICE_PREFIX1 ++
                                                         ?SERVICE_SUFFIX1,
                                                         <<"request">>),
  -            {ok, _, _} = cloudi_service:recv_async(Dispatcher, TransId)
  +            {ok, _, _} = cloudi_service:recv_async(Dispatcher, TransId),
  +            undefined
       end,
  -    {ok, #state{mode = Mode}}.
  +    {ok, #state{mode = NewMode}}.
   
   cloudi_service_handle_request(Type, Name, Pattern,
                                 ?REQUEST_INFO1 = RequestInfo, ?REQUEST1 = Request,
  
positive.code:                                                         ?REQUEST2),
      true = cloudi_x_uuid:is_v1(TransId2),
      true = (TransId2 > TransId1),
      ok.
  
  t_service_internal_async_1(_Config) ->
      Context = cloudi:new(),
      ServiceName = ?SERVICE_PREFIX1 ++ ?SERVICE_SUFFIX1,
      Self = self(),
  
negative.code: 
  %% test callbacks
  -export([t_service_internal_sync_1/1,
           t_service_internal_async_1/1,
           t_service_internal_async_2/1,
           t_service_internal_async_3/1]).
  
  -record(state,
      {
  