anchor.diff:      case lists:member({tail_mode,true},Opts) of
           false ->
               % io:format(user, "~p - fetch complete no tail ~p~n", [?MODULE,Opts]), 
  -            {noreply, State#state{fetchCtx=FetchCtx0#fetchCtx{status=done}}};           % ,reply=undefined
  +            {noreply, State#state{fetchCtx=FetchCtx0#fetchCtx{status=done}}};           
           true ->     
               {_Schema,Table,_Alias} = hd(Stmt#statement.tables),
  -            io:format(user, "~p - fetch complete, tail now~p~n", [?MODULE,Opts]), 
  +            io:format(user, "~p - fetch complete, switching to tail_mode~p~n", [?MODULE,Opts]), 
               case  catch if_call_mfa(false,subscribe,[none,{table,Table,simple}]) of
                   ok ->
                       io:format(user, "~p - Subscribed to table changes ~p~n", [?MODULE, Table]),    
  
positive.code: 
  -record(state,                  %% state for statment process, including fetch subprocess
                      { statement
                      , seco=none
                      , fetchCtx=#fetchCtx{}    
                      , reply                 %% reply destination TCP socket or Pid
                      , updPlan = []          %% bulk execution plan (table updates/inserts/deletes)
                      }).
  
  %% gen_server -----------------------------------------------------
  
negative.code:         {ok, _Clm3, _RowFun3, StmtRef3} = imem_sql:exec(SKey, Sql3, 100, 'Imem', IsSec),
          try
              ?assertEqual(ok, fetch_recs_async(SKey, StmtRef3, self(), [{tail_mode,true}], IsSec)),
              List3a = receive_list(StmtRef3,true),
              ?assertEqual(5, length(List3a)),
              ?assertEqual(ok, insert_range(SKey, 10, def, 'Imem', IsSec)),
              ?assertEqual(10,imem_meta:table_size(def)),  %% unchanged, all updates
              List3b = receive_list(StmtRef3,tail),
              ?assertEqual(5, length(List3b)),             %% 10 updates, 5 filtered with TailFun()           
              ?assertEqual(ok, fetch_close(SKey, StmtRef3, IsSec)),
              ?assertEqual(ok, insert_range(SKey, 5, def, 'Imem', IsSec)),
              ?assertEqual([], receive_raw())        
          after
              ?assertEqual(ok, close(SKey, StmtRef3))
          end,
  