Package net.sf.okapi.common.pipeline

Interface ICallableStep<T>

Type Parameters:

T - - return type of call method, i.e. Event, SortableEvent

All Superinterfaces:

AutoCloseable, Callable<T>, Function<Stream<Event>,Stream<Event>>, IPipelineStep

public interface ICallableStep<T>
extends IPipelineStep, Callable<T>

Step that implements the Callable interface and can be run concurrently.

Method Summary

Modifier and Type	Method	Description
IPipelineStep	getMainStep()	Gets the main step wrapped by ICallableStep
Event	processNow(Event event)	process the event now without threading.

Methods inherited from interface java.util.concurrent.Callable

call

Methods inherited from interface java.util.function.Function

andThen, compose

Methods inherited from interface net.sf.okapi.common.pipeline.IPipelineStep

apply, cancel, close, destroy, getDescription, getHelpLocation, getName, getParameters, getSourceLocale, getTargetLocale, handleEvent, handleStream, isDone, isLastOutputStep, setLastOutputStep, setParameters, setSourceLocale, setTargetLocale

Method Detail

getMainStep

IPipelineStep getMainStep()

Gets the main step wrapped by ICallableStep

Returns:

the main step

processNow

Event processNow(Event event)

process the event now without threading. Normally used for initialization events such as START_BATCH etc.

Parameters:

event - - event to be processed

Returns:

the resulting event