public class ClientRunnableBuffer<E,V> extends ClientBuffer<E> implements IRunnableBuffer<E>
Serializable class wraps a RemoteRunnableBuffer delegating
methods through to the IRunnableBuffer on the remote service while
masquerading IOExceptions so that we can implement the
IRunnableBuffer API.| Constructor and Description |
|---|
ClientRunnableBuffer(RemoteRunnableBuffer<E,V> buffer) |
| Modifier and Type | Method and Description |
|---|---|
void |
abort(Throwable cause)
Signal abnormal termination of the process writing on the buffer.
|
void |
close()
Signal that no more data will be written on this buffer (this is required
in order for the iterator to know when no more data will be made
available).
|
Future<V> |
getFuture()
The
Future for the worker task. |
boolean |
isOpen()
Return
true if the buffer is open. |
add, flush, isEmpty, reset, sizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddpublic ClientRunnableBuffer(RemoteRunnableBuffer<E,V> buffer)
buffer - public boolean isOpen()
IRunnableBuffertrue if the buffer is open.isOpen in interface IRunnableBuffer<E>public void abort(Throwable cause)
IRunnableBufferabort in interface IRunnableBuffer<E>cause - The exception thrown by the processing writing on the buffer.public void close()
IRunnableBufferclose in interface IRunnableBuffer<E>public Future<V> getFuture()
IRunnableBufferFuture for the worker task.getFuture in interface IRunnableBuffer<E>Future -or- null if no Future
has been set.Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.