com.github.davidmoten.rx.internal.operators

Class FileBasedSPSCQueueMemoryMappedReaderWriter<T>

java.lang.Object

com.github.davidmoten.rx.internal.operators.FileBasedSPSCQueueMemoryMappedReaderWriter<T>

public class FileBasedSPSCQueueMemoryMappedReaderWriter<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
FileBasedSPSCQueueMemoryMappedReaderWriter(File file, int fileSize, DataSerializer<T> serializer)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeForRead()
void	closeForWrite()
boolean	offer(T t) Returns true if value written to file or false if not enough space (writes and end-of-file marker in the fixed-length memory mapped file).
FileBasedSPSCQueueMemoryMappedReaderWriter<T>	openForRead()
FileBasedSPSCQueueMemoryMappedReaderWriter<T>	openForWrite()
T	poll()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileBasedSPSCQueueMemoryMappedReaderWriter

public FileBasedSPSCQueueMemoryMappedReaderWriter(File file,
                                                  int fileSize,
                                                  DataSerializer<T> serializer)

Method Detail

openForRead

public FileBasedSPSCQueueMemoryMappedReaderWriter<T> openForRead()

closeForRead

public void closeForRead()

openForWrite

public FileBasedSPSCQueueMemoryMappedReaderWriter<T> openForWrite()

closeForWrite

public void closeForWrite()

poll

public T poll()

offer

public boolean offer(T t)

Returns true if value written to file or false if not enough space (writes and end-of-file marker in the fixed-length memory mapped file).

Parameters:

t - value to write to the serialized queue

Returns:

true if written, false if not enough space

close

public void close()