anchor.diff:      DataFile.
   
   retrieve_data(Operation, StreamID, ConditionList) ->
  -    DataFile = retrieve_data_init(StreamID),
  -    retrieve_data(Operation, DataFile, [], ConditionList)
  +    [At | _] = ConditionList,
  +    DataFile = retrieve_data_init(StreamID, At),
  +    FoundData = retrieve_data(Operation, DataFile, [], ConditionList),
  +    list_to_binary(lists:flatten(lists:reverse(FoundData)))
       .
   
  -retrieve_data_init(StreamID) ->
  +retrieve_data_init(StreamID, At) ->
       {ok, File} = cake_stream_manager:stream_filename(StreamID),
       Offset = get_indexed_offset(StreamID, At),
       lager:debug("Offset from get_indexed_offset: ~p", [Offset]),
  
positive.code: %% Thoughs on defining MESSAGE_PACKAGE as [?MESSAGE_HEADER, ?MESSAGE] or <<?MESSAGE_HEADER, ?MESSAGE>> for evolution.
  %% At this time, only TS, Size and Data are necessary for operation functions.
  %% CRC32 is processed at an upper level.
  -define(MESSAGE_PACKAGE, [TS:64/native-integer, Size:32/native-integer, Data:Size/binary]).
  
  
  
  
negative.code:         {ok, ?MESSAGE_HEADER} ->
              case file:read(DataFile, Size+3) of
                  {ok,?MESSAGE} -> case CRC32 == erlang:crc32(Data) of
                                                  true -> retrieve_data(Operation, DataFile, FoundData, ConditionList, ?MESSAGE_PACKAGE);
                                                  false -> ok = file:close(DataFile),
                                                           lager:warning("Message: CRC32 Checksum failed on ~p", [TS]),
                                                           FoundData
  