tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseParserTest.java [85:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		flow = spy(flow);
		when(flow.getRecordSplitter()).thenReturn(new AggregationSplitter(recordSizeHint));
		Path testFile = FileSystems.getDefault().getPath(this.getClass().getResource(fileName).getFile());
		FirehoseParser parser = buildParser();
		parser = spy(parser);
		TrackedFile file = new TrackedFile(flow, testFile);
		file.open(0);
		assertTrue(parser.switchParsingToFile(file));
		List<FirehoseRecord> records = parseAllRecords(parser, null);
		assertEquals(records.size(), expectedRecordCount);
		assertAggregationParsedRecordsMatchInputFiles(records, recordSizeHint, testFile);
		verify(parser, never()).onDiscardedData(anyInt(), anyInt(), anyString());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseParserTest.java [108:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		flow = spy(flow);
		when(flow.getRecordSplitter()).thenReturn(new AggregationSplitter(recordSizeHint));
		Path testFile = FileSystems.getDefault().getPath(this.getClass().getResource(fileName).getFile());
		FirehoseParser parser = buildParser();
		parser = spy(parser);
		TrackedFile file = new TrackedFile(flow, testFile);
		file.open(0);
		assertTrue(parser.switchParsingToFile(file));
		List<FirehoseRecord> records = parseAllRecords(parser, null);
		assertEquals(records.size(), expectedRecordCount);
		assertAggregationParsedRecordsMatchInputFiles(records, recordSizeHint, testFile);
		verify(parser, never()).onDiscardedData(anyInt(), anyInt(), anyString());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -