Module org.apache.jena.serviceplugins

Package org.apache.jena.sparql.service.enhancer.slice.api

Class IteratorOverReadableChannel<T>

java.lang.Object

com.google.common.collect.UnmodifiableIterator<T>

com.google.common.collect.AbstractIterator<T>

org.apache.jena.sparql.service.enhancer.slice.api.IteratorOverReadableChannel<T>

All Implemented Interfaces:

Iterator<T>, org.apache.jena.atlas.iterator.IteratorCloseable<T>, org.apache.jena.atlas.lib.Closeable

public class IteratorOverReadableChannel<T>
extends com.google.common.collect.AbstractIterator<T>
implements org.apache.jena.atlas.iterator.IteratorCloseable<T>

Constructor Summary

Constructors

Constructor	Description
IteratorOverReadableChannel(ArrayOps<T[]> arrayOps, ReadableChannel<T[]> dataStream, int internalBufferSize)

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class com.google.common.collect.AbstractIterator

hasNext, next, peek

Methods inherited from class com.google.common.collect.UnmodifiableIterator

remove

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Constructor Details

IteratorOverReadableChannel

public IteratorOverReadableChannel(ArrayOps<T[]> arrayOps,
 ReadableChannel<T[]> dataStream,
 int internalBufferSize)

Parameters:

arrayOps -

dataStream -

internalBufferSize - The number of items to read from the dataStream at once.

Method Details

close

public void close()

Specified by:

close in interface org.apache.jena.atlas.lib.Closeable