anchor.diff:                  queue,      % queue of pending requests
                   connects=0, % number of successful connects
                   failed=[],  % breakdown of failed connects
  +                connect_timeout=infinity, % timeout of TCP connection
                   reconnect_interval=?FIRST_RECONNECT_INTERVAL}).
   -record(request, {ref :: reference(), msg :: rpb_req(), from, ctx :: ctx(), timeout :: integer(),
                     tref :: reference() | undefined }).
  
positive.code: 
  bad_connect_test() ->
      %% Start with an unlikely port number
      ?assertEqual({error, econnrefused}, start({127,0,0,1}, 65535)).
  
  queue_disconnected_test() ->
      %% Start with an unlikely port number
  
negative.code:         _ ->
              State
      end;
  parse_options([{connect_timeout, T}|Options], State) when is_integer(T) ->
      parse_options(Options, State#state{connect_timeout = T});
  parse_options([{queue_if_disconnected,Bool}|Options], State) when 
        Bool =:= true; Bool =:= false ->
      parse_options(Options, State#state{queue_if_disconnected = Bool});
  