added concept of *StreamExecutorService, and added 2 (untested) versions of it: Async (to support how driver currently works) & UniformWindowed (to support the windowed execution mode with Uniform window scheduling)
a lot is not tested at present