anchor.diff:      end,
       ok. 
   
  -receive_all() ->
  -    receive_all([]).
  -
  -receive_all(Acc) ->    
  -    case receive 
  -            R ->    io:format(user, "~p got:~n~p~n", [erlang:now(),R]),
  -                    R
  -        after 50 ->
  -            stop
  -        end of
  -        stop ->     lists:reverse(Acc);
  -        Result ->   receive_all([Result|Acc])
  -    end.
  -
  -receive_all_silently() ->
  -    receive_all_silently([]).
  -
  -receive_all_silently(Acc) ->    
  -    case receive 
  -            R ->    % io:format(user, "~p got:~n~p~n", [erlang:now(),R]),
  -                    R
  -        after 500 ->
  -            stop
  -        end of
  -        stop ->     lists:reverse(Acc);
  -        Result ->   receive_all([Result|Acc])
  -    end.
  -
   
   insert_range(_SKey, 0, _Table, _Schema, _IsSec) -> ok;
   insert_range(SKey, N, Table, Schema, IsSec) when is_integer(N), N > 0 ->
  
positive.code:     {_Schema,Table,_Alias} = hd(Stmt#statement.tables),
      catch if_call_mfa(false,unsubscribe,[none,{table,Table,simple}]).
  
  kill_fetch(MonitorRef, Pid) ->
      catch erlang:demonitor(MonitorRef, [flush]),
      catch Pid ! abort. 
  
negative.code:         io:format(user, "Query2: ~p~n", [Sql2]),
          {ok, _Clm2, _RowFun2, StmtRef2} = imem_sql:exec(SKey, Sql2, 4, "Imem", IsSec),
          ?assertEqual(ok, fetch_recs_async(SKey, StmtRef2, self(), IsSec)),
          List2a = receive_list(StmtRef2,false),
          ?assertEqual(4, length(List2a)),
          ?assertEqual([], receive_raw()),
          ?assertEqual(ok, fetch_recs_async(SKey, StmtRef2, self(), IsSec)),
          List2b = receive_list(StmtRef2,false),
          ?assertEqual(4, length(List2b)),
          ?assertEqual([], receive_raw()),
          ?assertEqual(ok, fetch_recs_async(SKey, StmtRef2, self(), IsSec)),
          List2c = receive_list(StmtRef2,false),
          ?assertEqual(4, length(List2c)),
          ?assertEqual(ok, fetch_recs_async(SKey, StmtRef2, self(), IsSec)),
          List2d = receive_list(StmtRef2,true),
          ?assertEqual(3, length(List2d)),
          io:format(user, "Result2:~n~p~n", [List2a ++ List2b ++ List2c ++ List2d]),
  
  
          %% ChangeList2 = [[OP,ID] ++ L || {OP,ID,L} <- lists:zip3([nop, ins, del, upd], [1,2,3,4], lists:map(RowFun2,List2a))],
          %% io:format(user, "change list~n~p~n", [ChangeList2]),
          ChangeList2 = [
  