tst/com/amazon/kinesis/streaming/agent/tailing/AggregationSplitterTest.java [74:85]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testLocateNextRecordGivenMultipleCompleteLinesAndOneIncompleteLineWithinRecordSizeHint() {
        final String[] lines = new String[] {
                "AA\n",
                "BB\n",
                "CC"
        };
        buffer = ByteBuffers.fromString(String.join("", lines), StandardCharsets.US_ASCII);

        Assert.assertEquals(splitter.locateNextRecord(buffer), lines[0].length() + lines[1].length());
        Assert.assertEquals(splitter.locateNextRecord(buffer), -1);
        Assert.assertEquals(buffer.position(), buffer.limit());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/AggregationSplitterTest.java [157:168]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testLocateNextRecordGivenMultipleCompleteLinesAndOneIncompleteLineBeyondRecordSizeHintCollectively() {
        final String[] lines = new String[] {
                "AAAA\n",
                "BBBB\n",
                "CCCC"
        };
        buffer = ByteBuffers.fromString(String.join("", lines), StandardCharsets.US_ASCII);

        Assert.assertEquals(splitter.locateNextRecord(buffer), lines[0].length() + lines[1].length());
        Assert.assertEquals(splitter.locateNextRecord(buffer), -1);
        Assert.assertEquals(buffer.position(), buffer.limit());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -