@Test public void writeCompressed() throws Exception { GCCloseable<FileChannel> fd = new GCCloseable<>(FileChannel.open(file.toPath(), StandardOpenOption.READ, StandardOpenOption.WRITE)); FilePos pos = writeable.write(new AbstractSegmentWriter.Writer(fd.get(), 0, Compression.DEFAULT_APPEND, false), new long[]{9}); assertEquals(xdrAble, new FileChannelSegmentReader<>(XdrAbleImpl::new, fd, pos, Compression.DEFAULT_APPEND).decode()); }
public FilePos write(Writer writer, long timestamps[]) throws OncRpcException, IOException { return writer.write(encode(timestamps)); }
AbstractSegmentWriter { public FilePos write(Writer writer, long timestamps[]) throws OncRpcException, IOException { return writer.write(encode(timestamps)); } }
AbstractSegmentWriter { public FilePos write(Writer writer, long timestamps[]) throws OncRpcException, IOException { return writer.write(encode(timestamps)); }  }
AbstractSegmentWriter { public FilePos write(Writer writer, long timestamps[]) throws OncRpcException, IOException { return writer.write(encode(timestamps)); }  abstract XdrAble encode(long timestamps[]); FilePos write(Writer writer, long timestamps[]); }
AbstractSegmentWriter { public FilePos write(Writer writer, long timestamps[]) throws OncRpcException, IOException { return writer.write(encode(timestamps)); }  abstract XdrAble encode(long timestamps[]); FilePos write(Writer writer, long timestamps[]);  }