anchor.diff:  
   handle_info({tcp, Sock, Data}, #state{req_type=catalogquery, reqid=ReqId, dest=Dest}=State) ->
       CatalogQueryResponse = raptor_pb:decode_catalogqueryresponse(Data),
  -    Dest ! {catalog_query, ReqId, CatalogQueryResponse#catalogqueryresponse.partition, 
  -                                  CatalogQueryResponse#catalogqueryresponse.index, 
  -                                  CatalogQueryResponse#catalogqueryresponse.field, 
  -                                  CatalogQueryResponse#catalogqueryresponse.term, 
  +    Dest ! {catalog_query, ReqId, CatalogQueryResponse#catalogqueryresponse.partition,
  +                                  CatalogQueryResponse#catalogqueryresponse.index,
  +                                  CatalogQueryResponse#catalogqueryresponse.field,
  +                                  CatalogQueryResponse#catalogqueryresponse.term,
                                     CatalogQueryResponse#catalogqueryresponse.json_props},
       NewState = if
                      CatalogQueryResponse#catalogqueryresponse.partition =:= "$end_of_results" ->
  
positive.code:          index/9,
           stream/8,
           info/5,
           info_range/6,
           catalog_query/2,
           catalog_query/3]).
  
negative.code:                end,
      {noreply, NewState};
  
  handle_info({tcp, _Sock, Data}, #state{req_type=command, reqid=ReqId, dest=Dest}=State) ->
      CommandResponse = raptor_pb:decode_commandresponse(Data),
      Dest ! {command, ReqId, CommandResponse#commandresponse.response},
      {noreply, State#state{req_type=undefined, reqid=undefined, dest=undefined}};
  