anchor.diff:  
   all() ->
     [
  -    collect_change,
  -    include_doc,
  -    collect_changes,
  -    changes_feed_callback,
  -    heartbeat_collect_change,
  -    heartbeat_and_timeout,
  -  	multiple_put,
  -    restart_when_server_timeout
  +  collect_change,
  +  include_doc,
  +  collect_changes,
  +  changes_feed_callback,
  +  heartbeat_collect_change,
  +  heartbeat_and_timeout,
  +  multiple_put,
  +  restart_when_server_timeout
     ].
   
   init_per_suite(Config) ->
  
positive.code:     {change, Change} ->
        collect_changes(I-1, queue:in(Change, Q))
    after 5000 ->
  					lager:notice("Queue on Timeout ~p", [Q]),
  					{error, timeout}
  							%collect_changes(0, queue:in({error, timeout}, Q))
    end.
  
  wait_pids([]) -> ok;
  
negative.code:   {ok, <<"bb">>, _} = barrel_httpc:post(db(Config), Doc2, []),
  
  
    receive
        {change, #{ <<"seq">> := 2, <<"id">> := <<"bb">>}}  ->
            ok
    after 5000 ->
            lager:notice("Seq 2 timeout",[]),
            throw(timeout)
    end,
  
  
    receive {change, #{ <<"seq">> := 1, <<"id">> := Val}} ->
            ok;
            _E ->
            lager:notice("Recived 1 ~p",[_E])
    after 5000 ->
            lager:notice("Seq 1 timeout",[]),
            throw(timeout)
    end,
    %% ok = case collect_changes(2, queue:new()) of
    %%           [
    %%            #{ <<"seq">> := 1, <<"id">> := Val},
    %%            #{ <<"seq">> := 2, <<"id">> := <<"bb">>}
    %%           ] -> ok;
    %%        _E ->
    %%            lager:info("Returned ~p~n",[_E]),
    %%            false
    %%    end,
    ok = application:stop(barrel_rest),
    {error, timeout} = collect_changes(1, queue:new()),
    ok = barrel_httpc_changes:stop(Pid),
  