ome.smuggler.core.service.file.impl

Class TaskIdPathStore<T extends util.object.Identifiable>

java.lang.Object

ome.smuggler.core.service.file.impl.TaskIdPathStore<T>

All Implemented Interfaces:

TaskFileStore<T>

public class TaskIdPathStore<T extends util.object.Identifiable>
extends java.lang.Object
implements TaskFileStore<T>

A TaskFileStore based on TaskIdPath.

Constructor Summary

Constructors

Constructor and Description
TaskIdPathStore(java.nio.file.Path storeDir, java.util.function.Function<java.lang.String,T> newTaskId) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	add(T taskId, util.lambda.ConsumerE<java.io.OutputStream> contentWriter) Writes a file associated to the specified task.
void	add(T taskId, java.nio.file.Path contentSource) Writes a file associated to the specified task by taking the contents from a source file.
java.util.stream.Stream<T>	listTaskIds()
java.nio.file.Path	pathFor(T taskId) Builds the path to the file associated to the given task ID.
void	remove(T taskId) Deletes the file associated to the specified task ID.
void	replace(T taskId, StreamFilter filter) Uses a filter function to replace the content of the file associated to the specified task.
java.nio.file.Path	storeDir()

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.service.file.TaskFileStore

add, replace

Constructor Detail

TaskIdPathStore

public TaskIdPathStore(java.nio.file.Path storeDir,
                       java.util.function.Function<java.lang.String,T> newTaskId)

Creates a new instance.

Parameters:

storeDir - the directory where files are stored.

newTaskId - creates a task id from its string representation.

Throws:

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

Method Detail

pathFor

public java.nio.file.Path pathFor(T taskId)

Description copied from interface: TaskFileStore

Builds the path to the file associated to the given task ID.

Specified by:

pathFor in interface TaskFileStore<T extends util.object.Identifiable>

Parameters:

taskId - the task ID.

Returns:

the path associated to the ID.

listTaskIds

public java.util.stream.Stream<T> listTaskIds()

Specified by:

listTaskIds in interface TaskFileStore<T extends util.object.Identifiable>

Returns:

the task ID's of all files currently stored in the directory.

The following checked exceptions are rethrown as unchecked (i.e. the exception is masked as a runtime exception and thrown as is without wrapping it in a RuntimeException):
IOException if an I/O occurs.

remove

public void remove(T taskId)

Description copied from interface: TaskFileStore

Deletes the file associated to the specified task ID.

Specified by:

remove in interface TaskFileStore<T extends util.object.Identifiable>

Parameters:

taskId - the task ID.

add

public void add(T taskId,
                util.lambda.ConsumerE<java.io.OutputStream> contentWriter)

Description copied from interface: TaskFileStore

Writes a file associated to the specified task. If the file already exists, it will be overwritten.

Specified by:

add in interface TaskFileStore<T extends util.object.Identifiable>

Parameters:

taskId - identifies the task.

contentWriter - writes the file contents into an output stream.

add

public void add(T taskId,
                java.nio.file.Path contentSource)

Description copied from interface: TaskFileStore

Writes a file associated to the specified task by taking the contents from a source file. If the file already exists in the store, it will be overwritten. (The source file is never modified though.)

Specified by:

add in interface TaskFileStore<T extends util.object.Identifiable>

Parameters:

taskId - identifies the task.

contentSource - the file contents to use.

replace

public void replace(T taskId,
                    StreamFilter filter)

Description copied from interface: TaskFileStore

Uses a filter function to replace the content of the file associated to the specified task.

Specified by:

replace in interface TaskFileStore<T extends util.object.Identifiable>

Parameters:

taskId - identifies the task.

filter - gets passed the current content of the file and produces the new file content.

See Also:

TaskFileStore.replace(Identifiable, FunctionE)

storeDir

public java.nio.file.Path storeDir()