com.bigdata.service.proxy
Class RemoteRunnableBufferImpl<E,V>

java.lang.Object
  com.bigdata.service.proxy.RemoteBufferImpl<E>
      com.bigdata.service.proxy.RemoteRunnableBufferImpl<E,V>

Type Parameters:

E - The generic type of the elements in the buffer.

V - The generic type of the result of the method call.

All Implemented Interfaces:

RemoteBuffer<E>, RemoteRunnableBuffer<E,V>, Remote

public class RemoteRunnableBufferImpl<E,V>
extends RemoteBufferImpl<E>
implements RemoteRunnableBuffer<E,V>

A helper object that provides the API of IBlockingBuffer but whose methods throw IOException and are therefore compatible with Remote and Exporter.

Version:

$Id: RemoteRunnableBufferImpl.java 2265 2009-10-26 12:51:06Z thompsonbry $

Author:

Bryan Thompson

Constructor Summary

RemoteRunnableBufferImpl(IRunnableBuffer<E> localBuffer, Future<V> futureProxy)

Method Summary

void	abort(Throwable cause)
void	close()
Future<V>	getFuture()
boolean	isOpen()

Methods inherited from class com.bigdata.service.proxy.RemoteBufferImpl

add, flush, isEmpty, reset, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.proxy.RemoteRunnableBuffer

add

Methods inherited from interface com.bigdata.service.proxy.RemoteBuffer

flush, isEmpty, reset, size

Constructor Detail

RemoteRunnableBufferImpl

public RemoteRunnableBufferImpl(IRunnableBuffer<E> localBuffer,
                                Future<V> futureProxy)

Parameters:

localBuffer -

futureProxy -

Method Detail

abort

public void abort(Throwable cause)
           throws IOException

Specified by:

abort in interface RemoteRunnableBuffer<E,V>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface RemoteRunnableBuffer<E,V>

Throws:

IOException

isOpen

public boolean isOpen()
               throws IOException

Specified by:

isOpen in interface RemoteRunnableBuffer<E,V>

Throws:

IOException

getFuture

public Future<V> getFuture()
                    throws IOException

Specified by:

getFuture in interface RemoteRunnableBuffer<E,V>

Throws:

IOException