@Test public void testOnBufferSplitNoTrailingDelimiter() throws IOException { final byte[] inputData = "Yes\nNo".getBytes(StandardCharsets.UTF_8); final ByteArrayInputStream is = new ByteArrayInputStream(inputData); final TextLineDemarcator demarcator = new TextLineDemarcator(is, 3); final OffsetInfo first = demarcator.nextOffsetInfo(); final OffsetInfo second = demarcator.nextOffsetInfo(); final OffsetInfo third = demarcator.nextOffsetInfo(); assertNotNull(first); assertNotNull(second); assertNull(third); assertEquals(0, first.getStartOffset()); assertEquals(4, first.getLength()); assertEquals(1, first.getCrlfLength()); assertEquals(4, second.getStartOffset()); assertEquals(2, second.getLength()); assertEquals(0, second.getCrlfLength()); }
public OffsetInfo nextOffsetInfo() throws IOException { return this.nextOffsetInfo(null); }
TextLineDemarcator extends AbstractDemarcator { public OffsetInfo nextOffsetInfo() throws IOException { return this.nextOffsetInfo(null); } }
TextLineDemarcator extends AbstractDemarcator { public OffsetInfo nextOffsetInfo() throws IOException { return this.nextOffsetInfo(null); } TextLineDemarcator(InputStream is);  TextLineDemarcator(InputStream is, int initialBufferSize); }
TextLineDemarcator extends AbstractDemarcator { public OffsetInfo nextOffsetInfo() throws IOException { return this.nextOffsetInfo(null); } TextLineDemarcator(InputStream is);  TextLineDemarcator(InputStream is, int initialBufferSize); OffsetInfo nextOffsetInfo(); OffsetInfo nextOffsetInfo(byte[] startsWith); }
TextLineDemarcator extends AbstractDemarcator { public OffsetInfo nextOffsetInfo() throws IOException { return this.nextOffsetInfo(null); } TextLineDemarcator(InputStream is);  TextLineDemarcator(InputStream is, int initialBufferSize); OffsetInfo nextOffsetInfo(); OffsetInfo nextOffsetInfo(byte[] startsWith);  }