Example implementation/usage of stream processor which does no I/O and thus can is also used as a unit test
"stream" or "generator" class, one which keeps producing new records for processing at throttled rate
Example of processing task, one which is managed by StreamProcessor and gets scheduled for each new record arriving from Generator
See Source File
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).
Copyright (c) 2009-2016 dunnhumby Germany GmbH. All rights reserved.
Example implementation/usage of stream processor which does no I/O and thus can is also used as a unit test