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(?APPEND,Message)).
  
  simple_query(StreamID,Start,End) ->
      Message = list_to_binary([ <<StreamID:16>>, <<Start:64>>, <<End:64>>]),
      tcp_query(?HOST,?PORT,packet(?QUERY,Message)).
  
  all_since(StreamID,Time) ->
      Message = list_to_binary([ <<StreamID:16>>, <<Time:64>>]),
      tcp_query(?HOST,?PORT,packet(?ALL_SINCE,Message)).
  
  request_stream(StreamName) ->
  
negative.code:             application:start(cake),
              {History,State,Result} = run_commands(?MODULE, Cmds),
              application:stop(cake),
  %            [cake_streams_statem:cleanup(X) || {_,X,_} <- element(3,State)],
              ?WHENFAIL(
                  io:format("\n\nHistory: ~w\n\nState: ~w\n\nResult: ~w\n\n",
                  [History,State,Result]),
  