anchor.diff:  %% ------------------------------------------------------------------
   
   init([AccountId, Username, Password, UserId]) ->
  -    {ok, ReqId} = start_stream(Username, Password, UserId),
  -    {ok, #state{account_id=AccountId, user_id=UserId, request_id=ReqId}}.
  +    {ok, #state{account_id=AccountId, user_id=UserId,
  +                username=Username, password=Password}, 0}.
   
   handle_call(_Msg, _From, State) ->
       {noreply, State}.
  
positive.code: %% ------------------------------------------------------------------
  
  -export([start_link/4, create/4, start_stream/3]).
  -record(state, {account_id, request_id, user_id}).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Exports
  
negative.code:                                TweetJSON),
      {noreply, State};
  handle_info({http, {_, stream_end, _}}, State) ->
      error_logger:info_msg("stream stopped.~n"),
      {noreply, State, 0};
  handle_info({http, {_, {error, Reason}}}, State) ->
      error_logger:info_msg("stream error ~p~n", [Reason]),
      {noreply, State, 1000};
  handle_info(timeout, #state{username = Username,
                              password = Password,
                              user_id = UserId} = State) ->
      {ok, ReqId} = start_stream(Username, Password, UserId),
      {noreply, State#state{request_id=ReqId}};
  handle_info(Msg, State) ->
      error_logger:warning_msg("Unknown Message: ~p~n", [Msg]),
      {noreply, State}.
  