anchor.diff:      {noreply, State}.
   
   
  +handle_info({http, {R, {{_, 420, _}, _H, _Body}}}, State=#state{request_id=R, backoff=B}) ->
  +    {noreply, reconnect(State#state{backoff=2*B})};
  +
   handle_info({http, {_, stream_start, _Headers}}, State) ->
       {noreply, State};
   
  
positive.code:     timer:sleep(B*10),
      {noreply, reconnect(State#state{backoff=2*B})};
  
  handle_info({http,{R,{error,socket_closed_remotely}}}, State=#state{request_id=R}) ->
      {noreply, reconnect(State)};
  
  
  handle_info(Info, State) ->
      lager:info("twitter: Unhandled message: ~p~n", [Info]),
  
negative.code: %% Internal Function Definitions
  %% ------------------------------------------------------------------
  
  reconnect(State=#state{request_id=R}) when R =/= undefined ->
      httpc:cancel_request(R),
      reconnect(State#state{request_id=undefined});
  
  reconnect(State=#state{backoff=B}) ->
      lager:info("twitter: Reconnect waiting ~p secs...", [B]),
      timer:sleep(1000*B),
      lager:info("twitter: Reconnect"),
  
      {ok, Login} = application:get_env(geoheap, twitter_username),
      {ok, Password} = application:get_env(geoheap, twitter_password),
  