Skip to content

Commit

Permalink
Address the comments.
Browse files Browse the repository at this point in the history
  • Loading branch information
horizonzy committed Aug 10, 2023
1 parent 114294c commit f8a68ef
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ public BufferedChannel(ByteBufAllocator allocator, FileChannel fc, int capacity,

public BufferedChannel(ByteBufAllocator allocator, FileChannel fc, int writeCapacity, int readCapacity,
long unpersistedBytesBound) throws IOException {
super(fc, readCapacity, false);
super(fc, readCapacity);
this.writeCapacity = writeCapacity;
this.position = fc.position();
this.writeBufferStartPosition.set(position);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,10 @@ public class BufferedReadChannel extends BufferedChannelBase {
private long fileSize = -1;
private final boolean sealed;

public BufferedReadChannel(FileChannel fileChannel, int readCapacity) {
this(fileChannel, readCapacity, false);
}

public BufferedReadChannel(FileChannel fileChannel, int readCapacity, boolean sealed) {
super(fileChannel);
this.sealed = sealed;
Expand Down

0 comments on commit f8a68ef

Please sign in to comment.