anchor.diff:                  _ -> EndSubTerm2 = EndSubTerm
               end,
               spawn_link(fun() ->
  +                {ok, Conn} = raptor_conn_sup:new_conn(),
                   {ok, StreamRef} = raptor_conn:stream(
                       Conn, 
                       list_to_binary(Index), 
  
positive.code: 
  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
  
negative.code: 
  handle_command(State, {info_range, Index, Field, StartTerm, EndTerm, _Size, 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_range(
              Conn, 
              list_to_binary(Index), 
  