StreamProcessor.process

Method to be called to start processing a record newly received from a stream.

class StreamProcessor(TaskT : Task)
void
process
(
ParametersOf!(TaskT.copyArguments) args
)

Parameters

args ParametersOf!(TaskT.copyArguments)

set of arguments to supply to processing task

Throws

ThrottlerFailureException if it is not possible to process data because task pool limit is reached.

Meta