anchor.diff:  
   handle_command(State, {stream, Index, Field, Term, SubType, StartSubTerm, EndSubTerm, OutputPid, OutputRef, DestPartition, Node, FilterFun}) ->
       Partition = list_to_binary(integer_to_list(State#state.partition)),
  -    {ok, Conn} = raptor_conn_sup:new_conn(),
       case DestPartition == State#state.partition andalso Node == node() of
           true ->
               case SubType of
  
positive.code: 
  handle_command(State, {info_range, Index, Field, StartTerm, EndTerm, _Size, OutputPid, OutputRef}) ->
      Partition = list_to_binary(integer_to_list(State#state.partition)),
      {ok, Conn} = raptor_conn_sup:new_conn(),
      spawn_link(fun() ->
          {ok, StreamRef} = raptor_conn:info_range(
              Conn, 
              list_to_binary(Index), 
  
negative.code: 
  handle_command(State, {info, Index, Field, Term, OutputPid, OutputRef}) ->
      Partition = list_to_binary(integer_to_list(State#state.partition)),
      spawn_link(fun() ->
          {ok, Conn} = raptor_conn_sup:new_conn(),
          {ok, StreamRef} = raptor_conn:info(
              Conn, 
              list_to_binary(Index), 
  