anchor.diff:                          partition=Partition,
                           message_type=MessageType},
       Ref = erlang:make_ref(),
  -    gen_server:call(ConnPid, {stream, self(), Ref, StreamRec}).
  +    gen_server:call(ConnPid, {stream, self(), Ref, StreamRec}, ?TIMEOUT).
   
   info(ConnPid, IndexName, FieldName, Term, Partition) ->
       MessageType = <<"Info">>,
  
positive.code:                     partition=Partition,
                      message_type=MessageType},
      Ref = erlang:make_ref(),
      gen_server:call(ConnPid, {info, self(), Ref, InfoRec}).
  
  info_range(ConnPid, IndexName, FieldName, StartTerm,
             EndTerm, Partition) ->
  
negative.code:          terminate/2, code_change/3]).
  
  -define(SERVER, ?MODULE).
  -define(TIMEOUT, 30000).
  
  -record(state, {sock, caller, req_type, reqid, dest}).
  
  