anchor.diff:                        subterm=SubTerm, value=Value,
                         partition=Partition,
                         message_type=MessageType},
  -    gen_server:call(ConnPid, {index, IndexRec}).
  +    gen_server:call(ConnPid, {index, IndexRec}, ?TIMEOUT).
   
   stream(ConnPid, IndexName, FieldName, Term, SubType, StartSubTerm,
          EndSubTerm, Partition) ->
  
positive.code:          terminate/2, code_change/3]).
  
  -define(SERVER, ?MODULE).
  
  -record(state, {sock, caller, req_type, reqid, dest}).
  
  
negative.code:                         partition=Partition,
                          message_type=MessageType},
      Ref = erlang:make_ref(),
      gen_server:call(ConnPid, {stream, self(), Ref, StreamRec}, ?TIMEOUT).
  
  info(ConnPid, IndexName, FieldName, Term, Partition) ->
      MessageType = <<"Info">>,
  