anchor.diff:                     mode=normal}=State) when Ts > LastFrom ->
       LastFrom1=send_entries(SubPid, [HistoryEntry], LastFrom),
       {noreply, State#state{last_from=LastFrom1}};
  -handle_cast(_Msg, State) ->
  +handle_cast(_Msg, #state{}=State) ->
       {noreply, State}.
   
  +% History pump done, hence enter normal mode (retranslation)
   handle_info(timeout, 
               #state{instance=InstanceName,
                      zlist=[],
  
positive.code:     LastFrom1=send_entries(SubPid, L, LastFrom),
      % Update state with tail zlist and new timestamp
      {noreply, State#state{zlist=ZList1,last_from=LastFrom1}, 1};
  handle_info(_Info, State) ->
      {noreply, State}.
  
  terminate(_Reason, _State) -> ok.
  
negative.code:     LastFrom1=send_entries(SubPid, ZList, LastFrom),
      % Switch mode to normal
      {noreply, State#state{last_from=LastFrom1,mode=normal}};
  % Do pump another one chunk to the subscriber (recovery)
  handle_info(timeout, 
              #state{zlist=ZList,
                     subscriber=SubPid,
  