anchor.diff:      oneof([
           {call,?MODULE,request_stream_with_size,[pos_integer(),streamname()]},
           {call,?MODULE,append,[streamid(S),list(integer(32,255))]},
  -        {call,?MODULE,simple_query,[streamid(S),S#state.starttime-10000,timestamp()+10000]},
  +%        {call,?MODULE,simple_query,[streamid(S),S#state.starttime-1000000000,timestamp()]},
  +        {call,?MODULE,simple_query,[streamid(S),S#state.starttime,timestamp()]},
           {call,?MODULE,all_since,[streamid(S),S#state.starttime]},
           {call,?MODULE,request_stream,[streamname()]},
           {call,?MODULE,last_entry_at,[streamid(S),timestamp()]}
  
positive.code:     tcp_query(?HOST,?PORT,packet(?REQUEST_STREAM,Message)).
   
  last_entry_at(StreamID,Time) ->
      Message = list_to_binary([ <<StreamID:16>>, <<Time:64>>]),
      tcp_query(?HOST,?PORT,packet(?LAST_ENTRY_AT,Message)).
  
  %%-----------------------------------------------------------------------------
  
negative.code: 
  % E.g. of model state structure:
  % {
  %   starttime = 13554171361963445,
  %   streams = [
  %     {StreamID_1, StreamName_1, [{TS_1,<<"DATA_1">>}, ..., {TS_M,<<"DATA_M">>}]},
  %     ...,
  