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

        Assert.assertEquals(splitter.locateNextRecord(buffer), -1);
        Assert.assertEquals(buffer.position(), buffer.limit());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



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

        Assert.assertEquals(splitter.locateNextRecord(buffer), -1);
        Assert.assertEquals(buffer.position(), buffer.limit());
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -