anchor.diff:  	    receive after 1 -> ok end,
   	    timeout_sink_loop(Action);
   	Other ->
  +            ?P("[sink-loop] action result: "
  +               "~n   ~p", [Other]),
   	    Other
       end.
        
  
positive.code:     
  setup_timeout_sink(RNode, Timeout, AutoClose) ->
      Host = get_hostname(node()),
      {ok, L} = gen_tcp:listen(0, [{active,             false},
                                   {packet,             2},
  				 {send_timeout,       Timeout},
  
negative.code: 		      die -> ok
  		  end
  	  end,
      ?P("[sink] start remote runner process (on ~p)", [RNode]),
      Pid =  rpc:call(RNode, erlang, spawn, [fun() -> Fun(Fun) end]),
      {ok, Port} = inet:port(L),
      Remote = fun(Fu) ->
  