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

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



tst/com/amazon/kinesis/streaming/agent/tailing/AggregationSplitterTest.java [88:97]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testLocateNextRecordGivenOneCompleteLineBeyondRecordSizeHint() {
        final String[] lines = new String[] {
                "AAAAAAAAAAAA\n"
        };
        buffer = ByteBuffers.fromString(String.join("", lines), StandardCharsets.US_ASCII);

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