- java.lang.Object
-
- de.siegmar.fastcsv.reader.ByteChannelStream
-
final class ByteChannelStream extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private java.nio.Buffer
buf
private java.nio.ByteBuffer
byteBuf
private java.nio.channels.ReadableByteChannel
channel
private CsvScanner.CsvListener
csvListener
private int
nextByte
private long
offset
-
Constructor Summary
Constructors Constructor Description ByteChannelStream(java.nio.channels.ReadableByteChannel channel, CsvScanner.CsvListener csvListener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
consumeIfNextEq(int val)
private int
fetchNextByte()
(package private) int
get()
(package private) long
getOffset()
(package private) boolean
hasData()
private boolean
loadData()
-
-
-
Field Detail
-
byteBuf
private final java.nio.ByteBuffer byteBuf
-
channel
private final java.nio.channels.ReadableByteChannel channel
-
csvListener
private final CsvScanner.CsvListener csvListener
-
offset
private long offset
-
nextByte
private int nextByte
-
buf
private final java.nio.Buffer buf
-
-
Constructor Detail
-
ByteChannelStream
ByteChannelStream(java.nio.channels.ReadableByteChannel channel, CsvScanner.CsvListener csvListener) throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
get
int get() throws java.io.IOException
- Throws:
java.io.IOException
-
consumeIfNextEq
boolean consumeIfNextEq(int val) throws java.io.IOException
- Throws:
java.io.IOException
-
hasData
boolean hasData()
-
getOffset
long getOffset()
-
fetchNextByte
private int fetchNextByte() throws java.io.IOException
- Throws:
java.io.IOException
-
loadData
private boolean loadData() throws java.io.IOException
- Throws:
java.io.IOException
-
-