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:                                     [],
                                      [{sync, false},
                                       {stream, self}]),
      State#state{request_id=RequestId}.
  
negative.code:     timer:sleep(B*10),
      {noreply, reconnect(State#state{backoff=2*B})};
  
  handle_info({http, {_, stream_end, _Headers}}, State) ->
      %% stream_end of previous stream, we're reconnecting
      {noreply, State};
  
  handle_info({http,{R,{error,Reason}}}, State=#state{request_id=R, backoff=B}) ->
      lager:info("twitter: Error ~p, restarting~n", [Reason]),
      {noreply, reconnect(State#state{backoff=2*B})};
  
  
  handle_info(reconnect, State) ->
      {noreply, reconnect(State)};
  
  handle_info(Info, State) ->
      lager:info("twitter: Unhandled message: ~p~n", [Info]),
  