anchor.diff:                                     end
                              end,
                          stream(Index, Field, Term, 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 }};
  +    NewPids = [ #stream_range{pid=StreamPid,
  +                              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({range, Index, Field, StartTerm, EndTerm, Size, Pid, Ref, FilterFun}, _From, State) ->
       #state { locks=Locks, 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  = NextID,
          scheduled_compaction = false,
          is_compacting = false,
          buffer_converter = Converter,
          stream_range_pids = []
      },
  
      %% Return.
  