anchor.diff:                                     end
                              end,
                          range(Index, Field, StartTerm, EndTerm, Size, F, Buffers, Segments),
  -                       Pid ! {result, '$end_of_table', Ref},
  -                       gen_server:call(Self, {stream_or_range_finished, Buffers, Segments}, infinity)
  +                       Pid ! {result, '$end_of_table', Ref}
                  end),
   
  -    {reply, ok, State#state { locks=NewLocks1 }};
  -    
  -handle_call({stream_or_range_finished, Buffers, Segments}, _From, State) ->
  -    #state { locks=Locks } = State,
  -
  -    %% Remove locks from all buffers...
  -    F1 = fun(Buffer, Acc) ->
  -        mi_locks:release(mi_buffer:filename(Buffer), Acc)
  -    end,
  -    NewLocks = lists:foldl(F1, Locks, Buffers),
  -
  -    %% Remove locks from all segments...
  -    F2 = fun(Segment, Acc) ->
  -        mi_locks:release(mi_segment:filename(Segment), Acc)
  -    end,
  -    NewLocks1 = lists:foldl(F2, NewLocks, Segments),
  -
  -    %% Return...
  -    {reply, ok, State#state { locks=NewLocks1 }};
  -
  -
  +    NewPids = [ #stream_range{pid=RangePid,
  +                              caller=Pid,
  +                              ref=Ref,
  +                              buffers=Buffers,
  +                              segments=Segments}
  +                | State#state.stream_range_pids ],
  +    {reply, ok, State#state { locks=NewLocks1,
  +                              stream_range_pids=NewPids }};
  +    
   handle_call({fold, FoldFun, Acc}, _From, State) ->
       #state { buffers=Buffers, segments=Segments } = State,
   
  
positive.code:          end,
      NewLocks1 = lists:foldl(F2, NewLocks, Segments),
  
      Self = self(),
      spawn_link(fun() ->
                         F = fun(Results) ->
                                     WrappedFilter = fun({Value, Props}) -> 
                                                             FilterFun(Value, Props) == true
  
negative.code:     next_id,
      scheduled_compaction,
      is_compacting,
      buffer_converter,
      stream_range_pids
  }).
  
  -record(stream_range, {
            pid,
            caller,
            ref,
            buffers,
            segments
           }).
  
  -define(RESULTVEC_SIZE, 1000).
  -define(DELETEME_FLAG, ".deleted").
  