com.asakusafw.windgate.stream

Class StreamSourceDriver<T>

java.lang.Object

com.asakusafw.windgate.stream.StreamSourceDriver<T>

Type Parameters:

T - type of data model objects

All Implemented Interfaces:

SourceDriver<T>, Preparable, Closeable, AutoCloseable

public class StreamSourceDriver<T>
extends Object
implements SourceDriver<T>

An implementation of SourceDriver using binary InputStream.

Since:

0.2.4

Constructor Summary

Constructors

Constructor and Description
StreamSourceDriver(String resourceName, String processName, InputStreamProvider streamProvider, DataModelStreamSupport<? super T> streamSupport, T buffer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Disposes this object.
T	get() Gets the current data model object prepared by the SourceDriver.next() method.
boolean	next() Returns true iff the next data model object exists, and then the SourceDriver.get() method returns its object.
void	prepare() Prepares this driver to invoke SourceDriver.next() method.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamSourceDriver

public StreamSourceDriver(String resourceName,
                          String processName,
                          InputStreamProvider streamProvider,
                          DataModelStreamSupport<? super T> streamSupport,
                          T buffer)

Creates a new instance.

Parameters:

resourceName - original resource name

processName - current process name

streamProvider - provides source InputStream

streamSupport - converts InputStream as data model objects

buffer - data model object for buffer

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

prepare

public void prepare()
             throws IOException

Description copied from interface: SourceDriver

Prepares this driver to invoke SourceDriver.next() method. This method will be invoked before SourceDriver.next() only once. This operation can execute only on the same thread as created this object.

Specified by:

prepare in interface SourceDriver<T>

Specified by:

prepare in interface Preparable

Throws:

IOException - if failed to begi

next

public boolean next()
             throws IOException

Description copied from interface: SourceDriver

Returns true iff the next data model object exists, and then the SourceDriver.get() method returns its object. This operation can execute only on the same thread as created this object.

Specified by:

next in interface SourceDriver<T>

Returns:

true if the next data model object exists, otherwise false

Throws:

IOException - if failed to prepare the next data

get

public T get()
      throws IOException

Description copied from interface: SourceDriver

Gets the current data model object prepared by the SourceDriver.next() method. This operation can execute only on the same thread as created this object.

Specified by:

get in interface SourceDriver<T>

Returns:

the next data model object

Throws:

IOException - if failed to prepare the next data

See Also:

SourceDriver.next()

close

public void close()
           throws IOException

Description copied from interface: SourceDriver

Disposes this object. This operation can execute only on the same thread as created this object.

Specified by:

close in interface SourceDriver<T>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - if failed to connect