com.github.davidmoten.rx2.internal.flowable.buffertofile

Class PagedQueue

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

com.github.davidmoten.rx2.internal.flowable.buffertofile.PagedQueue

All Implemented Interfaces:

Serializable

public class PagedQueue
extends AtomicInteger

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PagedQueue(Callable<File> fileFactory, int pageSize)

Method Summary

Modifier and Type	Method and Description
void	close()
void	offer(byte[] bytes)
byte[]	poll()

Methods inherited from class java.util.concurrent.atomic.AtomicInteger

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PagedQueue

public PagedQueue(Callable<File> fileFactory,
                  int pageSize)

Method Detail

offer

public void offer(byte[] bytes)

poll

public byte[] poll()

close

public void close()