tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseParserTest.java [35:45]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		flow = spy(flow);
		when(flow.getRecordSplitter()).thenReturn(new AggregationSplitter(recordSizeHint));
		Path testFile = testFiles.createTempFile();
		RecordGenerator generator = new RecordGenerator(averageRecordSize, recordSizeJitter);
		int lineCount = generator.appendDataToFile(testFile, getTestBytes());
		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);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseParserTest.java [60:70]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		flow = spy(flow);
		when(flow.getRecordSplitter()).thenReturn(new AggregationSplitter(recordSizeHint));
		Path testFile = testFiles.createTempFile();
		RecordGenerator generator = new RecordGenerator(averageRecordSize, recordSizeJitter);
		int lineCount = generator.appendDataToFile(testFile, getTestBytes());
		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);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -