ocean.task.util.StreamProcessor_test

Members

Classes

Generator
class Generator

"stream" or "generator" class, one which keeps producing new records for processing at throttled rate

ProcessingTask
class ProcessingTask

Example of processing task, one which is managed by StreamProcessor and gets scheduled for each new record arriving from Generator

Meta

License

Boost Software License Version 1.0. See LICENSE_BOOST.txt for details. Alternatively, this file may be distributed under the terms of the Tango 3-Clause BSD License (see LICENSE_BSD.txt for details).