@Test public void OneMessageTransferPosTest(){ ByteBuffer byteBuffer = ByteBuffer.allocate(20); byteBuffer.putInt(20); SelectMappedBufferResult selectMappedBufferResult = new SelectMappedBufferResult(0,byteBuffer,20,new MappedFile()); OneMessageTransfer manyMessageTransfer = new OneMessageTransfer(byteBuffer,selectMappedBufferResult); Assert.assertEquals(manyMessageTransfer.position(),8); }
@Override public long position() { return this.byteBufferHeader.position() + this.selectMappedBufferResult.getByteBuffer().position(); }
OneMessageTransfer extends AbstractReferenceCounted implements FileRegion { @Override public long position() { return this.byteBufferHeader.position() + this.selectMappedBufferResult.getByteBuffer().position(); } }
OneMessageTransfer extends AbstractReferenceCounted implements FileRegion { @Override public long position() { return this.byteBufferHeader.position() + this.selectMappedBufferResult.getByteBuffer().position(); } OneMessageTransfer(ByteBuffer byteBufferHeader, SelectMappedBufferResult selectMappedBufferResult); }
OneMessageTransfer extends AbstractReferenceCounted implements FileRegion { @Override public long position() { return this.byteBufferHeader.position() + this.selectMappedBufferResult.getByteBuffer().position(); } OneMessageTransfer(ByteBuffer byteBufferHeader, SelectMappedBufferResult selectMappedBufferResult); @Override long position(); @Override long transfered(); @Override long count(); @Override long transferTo(WritableByteChannel target, long position); void close(); }
OneMessageTransfer extends AbstractReferenceCounted implements FileRegion { @Override public long position() { return this.byteBufferHeader.position() + this.selectMappedBufferResult.getByteBuffer().position(); } OneMessageTransfer(ByteBuffer byteBufferHeader, SelectMappedBufferResult selectMappedBufferResult); @Override long position(); @Override long transfered(); @Override long count(); @Override long transferTo(WritableByteChannel target, long position); void close();  }