ome.smuggler.core.io

Class ValueFilter<T>

java.lang.Object

ome.smuggler.core.io.ValueFilter<T>

All Implemented Interfaces:

StreamFilter

Direct Known Subclasses:

StringFilter

public class ValueFilter<T>
extends java.lang.Object
implements StreamFilter

A StreamFilter that reads and writes T-values. This filter deserialises the input stream into memory as a T-value t, gives t to a setter function to produce a new T-value t', and then serialises t' to the output stream.

Constructor Summary

Constructors

Constructor and Description
ValueFilter(SourceReader<java.io.InputStream,T> reader, SinkWriter<T,java.io.OutputStream> writer, java.util.function.Function<T,T> setter) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	processE(java.io.InputStream in, java.io.OutputStream out) Reads from the input stream and writes to the output stream.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ome.smuggler.core.io.StreamFilter

process

Constructor Detail

ValueFilter

public ValueFilter(SourceReader<java.io.InputStream,T> reader,
                   SinkWriter<T,java.io.OutputStream> writer,
                   java.util.function.Function<T,T> setter)

Creates a new instance.

Parameters:

reader - deserialises the input stream.

writer - serialises a T-value to the output stream.

setter - given the deserialised value, produces the value to serialise to the output stream.

Throws:

java.lang.NullPointerException - if any argument is null.

Method Detail

processE

public void processE(java.io.InputStream in,
                     java.io.OutputStream out)
              throws java.lang.Exception

Description copied from interface: StreamFilter

Reads from the input stream and writes to the output stream. The caller is responsible for creating suitable streams and for closing them after this method returns.

Specified by:

processE in interface StreamFilter

Parameters:

in - the data to read.

out - where this method will write its output data.

Throws:

java.lang.NullPointerException - if any argument is null.

java.lang.Exception - If any other error occurs.